本文整理汇总了Java中storm.trident.planner.processor.TridentContext类的典型用法代码示例。如果您正苦于以下问题:Java TridentContext类的具体用法?Java TridentContext怎么用?Java TridentContext使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
TridentContext类属于storm.trident.planner.processor包,在下文中一共展示了TridentContext类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: prepare
import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
@Override
public void prepare(Map conf, TopologyContext context, TridentContext tridentContext) {
this.conf = conf;
this.topologyContext = context;
List<TridentTuple.Factory> parents = tridentContext.getParentTupleFactories();
if (parents.size() != 1) {
throw new RuntimeException("Aggregation related operation can only have one parent");
}
Long maxTuplesCacheSize = getWindowTuplesCacheSize(conf);
this.tridentContext = tridentContext;
collector = new FreshCollector(tridentContext);
projection = new TridentTupleView.ProjectionFactory(parents.get(0), inputFields);
windowStore = windowStoreFactory.create();
windowTaskId = windowId + WindowsStore.KEY_SEPARATOR + topologyContext.getThisTaskId() + WindowsStore.KEY_SEPARATOR;
windowTriggerInprocessId = getWindowTriggerInprocessIdPrefix(windowTaskId);
tridentWindowManager = storeTuplesInStore ?
new StoreBasedTridentWindowManager(windowConfig, windowTaskId, windowStore, aggregator, tridentContext.getDelegateCollector(), maxTuplesCacheSize, inputFields)
: new InMemoryTridentWindowManager(windowConfig, windowTaskId, windowStore, aggregator, tridentContext.getDelegateCollector());
tridentWindowManager.prepare();
}
开发者ID:alibaba,项目名称:jstorm,代码行数:26,代码来源:WindowTridentProcessor.java
示例2: prepare
import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
void prepare(Map conf, TopologyContext context, TridentContext tridentContext);
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:3,代码来源:TridentProcessor.java
示例3: prepare
import storm.trident.planner.processor.TridentContext; //导入依赖的package包/类
void prepare(Map conf, TopologyContext context, TridentContext tridentContext);
开发者ID:songtk,项目名称:learn_jstorm,代码行数:2,代码来源:TridentProcessor.java
注:本文中的storm.trident.planner.processor.TridentContext类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论