本文整理汇总了Java中backtype.storm.generated.NullStruct类的典型用法代码示例。如果您正苦于以下问题:Java NullStruct类的具体用法?Java NullStruct怎么用?Java NullStruct使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
NullStruct类属于backtype.storm.generated包,在下文中一共展示了NullStruct类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: maybeAddWatermarkInputs
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
/**
* Add watermark stream to source components of window bolts
*/
private void maybeAddWatermarkInputs(ComponentCommon common, IRichBolt bolt) {
if (bolt instanceof WindowedBoltExecutor) {
Set<String> comps = new HashSet<>();
for (GlobalStreamId globalStreamId : common.get_inputs().keySet()) {
comps.add(globalStreamId.get_componentId());
}
for (String comp : comps) {
common.put_to_inputs(
new GlobalStreamId(comp, Common.WATERMARK_STREAM_ID),
Grouping.all(new NullStruct()));
}
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:18,代码来源:TopologyBuilder.java
示例2: addCheckPointInputs
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
/**
* For bolts that has incoming streams from spouts (the root bolts),
* add checkpoint stream from checkpoint spout to its input. For other bolts,
* add checkpoint stream from the previous bolt to its input.
*/
private void addCheckPointInputs(ComponentCommon component) {
Set<GlobalStreamId> checkPointInputs = new HashSet<>();
for (GlobalStreamId inputStream : component.get_inputs().keySet()) {
String sourceId = inputStream.get_componentId();
if (_spouts.containsKey(sourceId)) {
checkPointInputs.add(new GlobalStreamId(CheckpointSpout.CHECKPOINT_COMPONENT_ID, CheckpointSpout.CHECKPOINT_STREAM_ID));
} else {
checkPointInputs.add(new GlobalStreamId(sourceId, CheckpointSpout.CHECKPOINT_STREAM_ID));
}
}
for (GlobalStreamId streamId : checkPointInputs) {
component.put_to_inputs(streamId, Grouping.all(new NullStruct()));
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:20,代码来源:TopologyBuilder.java
示例3: mkDirectGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public static Grouping mkDirectGrouping() {
return Grouping.direct(new NullStruct());
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:4,代码来源:Thrift.java
示例4: shuffle
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public Stream shuffle() {
return partition(Grouping.shuffle(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:4,代码来源:Stream.java
示例5: localOrShuffle
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public Stream localOrShuffle() {
return partition(Grouping.local_or_shuffle(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:4,代码来源:Stream.java
示例6: broadcast
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public Stream broadcast() {
return partition(Grouping.all(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:4,代码来源:Stream.java
示例7: shuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer shuffleGrouping(String componentId, String streamId) {
return grouping(componentId, streamId,
Grouping.shuffle(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:6,代码来源:TopologyBuilder.java
示例8: localOrShuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer localOrShuffleGrouping(String componentId,
String streamId) {
return grouping(componentId, streamId,
Grouping.local_or_shuffle(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:7,代码来源:TopologyBuilder.java
示例9: localFirstGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer localFirstGrouping(String componentId,
String streamId) {
return grouping(componentId, streamId,
Grouping.localFirst(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:7,代码来源:TopologyBuilder.java
示例10: noneGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer noneGrouping(String componentId, String streamId) {
return grouping(componentId, streamId,
Grouping.none(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:6,代码来源:TopologyBuilder.java
示例11: allGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer allGrouping(String componentId, String streamId) {
return grouping(componentId, streamId,
Grouping.all(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:6,代码来源:TopologyBuilder.java
示例12: directGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer directGrouping(String componentId, String streamId) {
return grouping(componentId, streamId,
Grouping.direct(new NullStruct()));
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:6,代码来源:TopologyBuilder.java
示例13: shuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer shuffleGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.shuffle(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:4,代码来源:TopologyBuilder.java
示例14: localOrShuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer localOrShuffleGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.local_or_shuffle(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:4,代码来源:TopologyBuilder.java
示例15: localFirstGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
@Override
public BoltDeclarer localFirstGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.localFirst(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:5,代码来源:TopologyBuilder.java
示例16: noneGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer noneGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.none(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:4,代码来源:TopologyBuilder.java
示例17: allGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer allGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.all(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:4,代码来源:TopologyBuilder.java
示例18: directGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer directGrouping(String componentId, String streamId) {
return grouping(componentId, streamId, Grouping.direct(new NullStruct()));
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:4,代码来源:TopologyBuilder.java
示例19: shuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer shuffleGrouping(String componentId, String streamId) {
return grouping(componentId, streamId,
Grouping.shuffle(new NullStruct()));
}
开发者ID:greeenSY,项目名称:Tstream,代码行数:5,代码来源:TopologyBuilder.java
示例20: localOrShuffleGrouping
import backtype.storm.generated.NullStruct; //导入依赖的package包/类
public BoltDeclarer localOrShuffleGrouping(String componentId,
String streamId) {
return grouping(componentId, streamId,
Grouping.local_or_shuffle(new NullStruct()));
}
开发者ID:greeenSY,项目名称:Tstream,代码行数:6,代码来源:TopologyBuilder.java
注:本文中的backtype.storm.generated.NullStruct类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论