Modifier and Type | Method and Description |
---|---|
void |
HBaseQuery.execute(TridentTuple tuples,
List<Values> values,
TridentCollector tridentCollector) |
void |
HBaseUpdater.updateState(HBaseState hBaseState,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
HBaseState.updateState(List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
HdfsUpdater.updateState(HdfsState state,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
HdfsState.updateState(List<TridentTuple> tuples,
TridentCollector tridentCollector) |
Modifier and Type | Method and Description |
---|---|
void |
TridentKafkaState.updateState(List<TridentTuple> tuples,
TridentCollector collector) |
void |
TridentKafkaUpdater.updateState(TridentKafkaState state,
List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
TridentWordCount.Split.execute(TridentTuple tuple,
TridentCollector collector) |
void |
TridentReach.ExpandList.execute(TridentTuple tuple,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
ReturnResultsReducer.complete(ReturnResultsReducer.ReturnResultsState state,
TridentCollector collector) |
void |
ReturnResultsReducer.execute(ReturnResultsReducer.ReturnResultsState state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
ReturnResultsReducer.ReturnResultsState |
ReturnResultsReducer.init(TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
Aggregator.aggregate(T val,
TridentTuple tuple,
TridentCollector collector) |
void |
MultiReducer.complete(T state,
TridentCollector collector) |
void |
Aggregator.complete(T val,
TridentCollector collector) |
void |
GroupedMultiReducer.complete(T state,
TridentTuple group,
TridentCollector collector) |
void |
MultiReducer.execute(T state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
void |
GroupedMultiReducer.execute(T state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
void |
Function.execute(TridentTuple tuple,
TridentCollector collector) |
T |
Aggregator.init(Object batchId,
TridentCollector collector) |
T |
MultiReducer.init(TridentCollector collector) |
T |
GroupedMultiReducer.init(TridentCollector collector,
TridentTuple group) |
Modifier and Type | Method and Description |
---|---|
void |
FirstN.FirstNAgg.aggregate(storm.trident.operation.builtin.FirstN.FirstNAgg.State val,
TridentTuple tuple,
TridentCollector collector) |
void |
FirstN.FirstNSortedAgg.aggregate(PriorityQueue state,
TridentTuple tuple,
TridentCollector collector) |
void |
FirstN.FirstNAgg.complete(storm.trident.operation.builtin.FirstN.FirstNAgg.State val,
TridentCollector collector) |
void |
FirstN.FirstNSortedAgg.complete(PriorityQueue val,
TridentCollector collector) |
void |
TupleCollectionGet.execute(TridentTuple tuple,
Iterator<List<Object>> tuplesIterator,
TridentCollector collector) |
void |
SnapshotGet.execute(TridentTuple tuple,
Object result,
TridentCollector collector) |
void |
MapGet.execute(TridentTuple tuple,
Object result,
TridentCollector collector) |
storm.trident.operation.builtin.FirstN.FirstNAgg.State |
FirstN.FirstNAgg.init(Object batchId,
TridentCollector collector) |
PriorityQueue |
FirstN.FirstNSortedAgg.init(Object batchId,
TridentCollector collector) |
Modifier and Type | Class and Description |
---|---|
class |
CaptureCollector |
class |
GroupCollector |
Modifier and Type | Method and Description |
---|---|
void |
ChainedAggregatorImpl.aggregate(ChainedResult val,
TridentTuple tuple,
TridentCollector collector) |
void |
GroupedAggregator.aggregate(Object[] arr,
TridentTuple tuple,
TridentCollector collector) |
void |
ReducerAggregatorImpl.aggregate(Result val,
TridentTuple tuple,
TridentCollector collector) |
void |
CombinerAggregatorCombineImpl.aggregate(Result val,
TridentTuple tuple,
TridentCollector collector) |
void |
SingleEmitAggregator.aggregate(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val,
TridentTuple tuple,
TridentCollector collector) |
void |
ChainedAggregatorImpl.complete(ChainedResult val,
TridentCollector collector) |
void |
JoinerMultiReducer.complete(JoinerMultiReducer.JoinState state,
TridentTuple group,
TridentCollector collector) |
void |
GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state,
TridentCollector collector) |
void |
GroupedAggregator.complete(Object[] arr,
TridentCollector collector) |
void |
IdentityMultiReducer.complete(Object state,
TridentCollector collector) |
void |
ReducerAggregatorImpl.complete(Result val,
TridentCollector collector) |
void |
CombinerAggregatorCombineImpl.complete(Result val,
TridentCollector collector) |
void |
SingleEmitAggregator.complete(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val,
TridentCollector collector) |
void |
JoinerMultiReducer.execute(JoinerMultiReducer.JoinState state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
void |
GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state,
int streamIndex,
TridentTuple full,
TridentCollector collector) |
void |
IdentityMultiReducer.execute(Object state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
void |
FilterExecutor.execute(TridentTuple tuple,
TridentCollector collector) |
void |
CombinerAggregatorInitImpl.execute(TridentTuple tuple,
TridentCollector collector) |
storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState |
SingleEmitAggregator.init(Object batchId,
TridentCollector collector) |
Result |
ReducerAggregatorImpl.init(Object batchId,
TridentCollector collector) |
Object[] |
GroupedAggregator.init(Object batchId,
TridentCollector collector) |
Result |
CombinerAggregatorCombineImpl.init(Object batchId,
TridentCollector collector) |
ChainedResult |
ChainedAggregatorImpl.init(Object batchId,
TridentCollector collector) |
Object |
IdentityMultiReducer.init(TridentCollector collector) |
Map<TridentTuple,Object> |
GroupedMultiReducerExecutor.init(TridentCollector collector) |
JoinerMultiReducer.JoinState |
JoinerMultiReducer.init(TridentCollector collector,
TridentTuple group) |
void |
CaptureCollector.setCollector(TridentCollector coll) |
void |
ChainedResult.setFollowThroughCollector(TridentCollector collector) |
void |
ReducerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
CombinerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
Constructor and Description |
---|
ChainedResult(TridentCollector collector,
int size) |
GroupCollector(TridentCollector collector,
ComboList.Factory factory) |
Modifier and Type | Class and Description |
---|---|
class |
AppendCollector |
class |
FreshCollector |
Modifier and Type | Method and Description |
---|---|
void |
IBatchSpout.emitBatch(long batchId,
TridentCollector collector) |
void |
OpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
TridentCollector collector) |
void |
BatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
TridentCollector collector) |
void |
ITridentSpout.Emitter.emitBatch(TransactionAttempt tx,
X coordinatorMeta,
TridentCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
M |
IOpaquePartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
M lastPartitionMeta)
Emit a batch of tuples for a partition/transaction.
|
void |
IPartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
X partitionMeta)
Emit a batch of tuples for a partition/transaction that has been emitted before, using
the metadata created when it was first emitted.
|
X |
IPartitionedTridentSpout.Emitter.emitPartitionBatchNew(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
X lastPartitionMeta)
Emit a batch of tuples for a partition/transaction that's never been emitted before.
|
Modifier and Type | Method and Description |
---|---|
void |
QueryFunction.execute(TridentTuple tuple,
T result,
TridentCollector collector) |
void |
StateUpdater.updateState(S state,
List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
MapReducerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
MapCombinerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
CountAsAggregator.aggregate(storm.trident.testing.CountAsAggregator.State state,
TridentTuple tuple,
TridentCollector collector) |
void |
CountAsAggregator.complete(storm.trident.testing.CountAsAggregator.State state,
TridentCollector collector) |
void |
FixedBatchSpout.emitBatch(long batchId,
TridentCollector collector) |
void |
FeederBatchSpout.FeederEmitter.emitBatch(TransactionAttempt tx,
Map<Integer,List<List<Object>>> coordinatorMeta,
TridentCollector collector) |
void |
TuplifyArgs.execute(TridentTuple input,
TridentCollector collector) |
void |
StringLength.execute(TridentTuple tuple,
TridentCollector collector) |
void |
Split.execute(TridentTuple tuple,
TridentCollector collector) |
storm.trident.testing.CountAsAggregator.State |
CountAsAggregator.init(Object batchId,
TridentCollector collector) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.