本文整理汇总了Java中storm.trident.tuple.TridentTupleView类的典型用法代码示例。如果您正苦于以下问题：Java TridentTupleView类的具体用法？Java TridentTupleView怎么用？Java TridentTupleView使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
TridentTupleView类属于storm.trident.tuple包，在下文中一共展示了TridentTupleView类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: aggregate
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Override
public void aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector) {
GroupCollector groupColl = (GroupCollector) arr[0];
Map<List, Object> val = (Map) arr[1];
TridentTuple group = _groupFactory.create((TridentTupleView) tuple);
TridentTuple input = _inputFactory.create((TridentTupleView) tuple);
Object curr;
if(!val.containsKey(group)) {
curr = _agg.init(arr[2], groupColl);
val.put((List) group, curr);
} else {
curr = val.get(group);
}
groupColl.currGroup = group;
_agg.aggregate(curr, input, groupColl);
}
开发者ID:songtk，项目名称:learn_jstorm，代码行数:18，代码来源:GroupedAggregator.java
示例2: aggregate
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Override
public void aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector) {
GroupCollector groupColl = (GroupCollector) arr[0];
Map<List, Object> val = (Map) arr[1];
TridentTuple group = _groupFactory.create((TridentTupleView) tuple);
TridentTuple input = _inputFactory.create((TridentTupleView) tuple);
Object curr;
if (!val.containsKey(group)) {
curr = _agg.init(arr[2], groupColl);
val.put((List) group, curr);
} else {
curr = val.get(group);
}
groupColl.currGroup = group;
_agg.aggregate(curr, input, groupColl);
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:18，代码来源:GroupedAggregator.java
示例3: prepare
import storm.trident.tuple.TridentTupleView; //导入依赖的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
示例4: emit
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
TridentTuple toEmit = _factory.create((TridentTupleView) tuple, values);
for(TupleReceiver r: _triContext.getReceivers()) {
r.execute(context, _triContext.getOutStreamId(), toEmit);
}
}
开发者ID:zhangjunfang，项目名称:jstorm-0.9.6.3-，代码行数:8，代码来源:AppendCollector.java
示例5: aggregate
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
public void aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector) {
val.setFollowThroughCollector(collector);
for(int i=0; i<_aggs.length; i++) {
TridentTuple projected = _inputFactories[i].create((TridentTupleView) tuple);
_aggs[i].aggregate(val.objs[i], projected, val.collectors[i]);
}
}
开发者ID:songtk，项目名称:learn_jstorm，代码行数:8，代码来源:ChainedAggregatorImpl.java
示例6: aggregate
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
public void aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector) {
val.setFollowThroughCollector(collector);
for (int i = 0; i < _aggs.length; i++) {
TridentTuple projected = _inputFactories[i].create((TridentTupleView) tuple);
_aggs[i].aggregate(val.objs[i], projected, val.collectors[i]);
}
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:8，代码来源:ChainedAggregatorImpl.java
示例7: emit
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Override
public void emit(List<Object> values) {
TridentTuple toEmit = _factory.create((TridentTupleView) tuple, values);
for (TupleReceiver r : _triContext.getReceivers()) {
r.execute(context, _triContext.getOutStreamId(), toEmit);
}
}
开发者ID:kkllwww007，项目名称:jstrom，代码行数:8，代码来源:AppendCollector.java
示例8: testWrite
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Test
public void testWrite() throws Exception {
S3TransactionalOutput<Long> output = new DefaultS3TransactionalOutput<Long>(1L, config, tx, fileOutputFactory);
output.prepare(config);
List<TridentTuple> tuples = Arrays.asList(TridentTupleView.createFreshTuple(new Fields("sentence"), "a"));
for (int i = 0; i < 513; i++) {
output.write(tuples, (long) i);
}
String bucketName = fileOutputFactory.buildBucketName(1L);
assertCorrectFileSize(bucketName, 512);
}
开发者ID:wurstmeister，项目名称:storm-s3，代码行数:12，代码来源:DefaultS3TransactionalOutputTest.java
示例9: testWriteOnlyOnTransactionBoundary
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Test
public void testWriteOnlyOnTransactionBoundary() throws Exception {
S3TransactionalOutput<Long> output = new DefaultS3TransactionalOutput<Long>(1L, config, tx, fileOutputFactory);
output.prepare(config);
List<TridentTuple> tuples = Arrays.asList(TridentTupleView.createFreshTuple(new Fields("sentence"), "a"));
for (int i = 0; i < 514; i++) {
output.write(tuples, 1L);
}
output.write(tuples, 2L);
String bucketName = fileOutputFactory.buildBucketName(1L);
assertCorrectFileSize(bucketName, 514);
}
开发者ID:wurstmeister，项目名称:storm-s3，代码行数:14，代码来源:DefaultS3TransactionalOutputTest.java
示例10: prepare
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
@Override
public void prepare(Map conf, TopologyContext context, TridentContext tridentContext) {
List<TridentTuple.Factory> parents = tridentContext.getParentTupleFactories();
if(parents.size()!=1) {
throw new RuntimeException("Map operation can only have one parent");
}
_context = tridentContext;
_collector = new FreshCollector(tridentContext);
_projection = new TridentTupleView.ProjectionFactory(parents.get(0), _inputFields);
_function.prepare(conf, new TridentOperationContext(context, _projection));
}
开发者ID:alibaba，项目名称:jstorm，代码行数:12，代码来源:MapProcessor.java
示例11: StoreBasedTridentWindowManager
import storm.trident.tuple.TridentTupleView; //导入依赖的package包/类
public StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator,
BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields) {
super(windowConfig, windowTaskId, windowStore, aggregator, delegateCollector);
this.maxCachedTuplesSize = maxTuplesCacheSize;
this.inputFields = inputFields;
freshOutputFactory = new TridentTupleView.FreshOutputFactory(inputFields);
windowTupleTaskId = TUPLE_PREFIX + windowTaskId;
}
开发者ID:alibaba，项目名称:jstorm，代码行数:10，代码来源:StoreBasedTridentWindowManager.java
注：本文中的storm.trident.tuple.TridentTupleView类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论