Uses of Interface
storm.trident.operation.TridentCollector

Packages that use TridentCollector

Package	Description
storm.trident.drpc
storm.trident.operation
storm.trident.operation.builtin
storm.trident.operation.impl
storm.trident.planner.processor
storm.trident.spout
storm.trident.state
storm.trident.state.map
storm.trident.testing

Uses of TridentCollector in storm.trident.drpc

Methods in storm.trident.drpc with parameters of type TridentCollector

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)

Uses of TridentCollector in storm.trident.operation

Methods in storm.trident.operation with parameters of type TridentCollector

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)

Uses of TridentCollector in storm.trident.operation.builtin

Methods in storm.trident.operation.builtin with parameters of type TridentCollector

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)

Uses of TridentCollector in storm.trident.operation.impl

Classes in storm.trident.operation.impl that implement TridentCollector

Modifier and Type	Class and Description
class	CaptureCollector
class	GroupCollector

Methods in storm.trident.operation.impl with parameters of type TridentCollector

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)
Result	ReducerAggregatorImpl.init(Object batchId, TridentCollector collector)
storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState	SingleEmitAggregator.init(Object batchId, TridentCollector collector)
Result	CombinerAggregatorCombineImpl.init(Object batchId, TridentCollector collector)
ChainedResult	ChainedAggregatorImpl.init(Object batchId, TridentCollector collector)
Object[]	GroupedAggregator.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)

Constructors in storm.trident.operation.impl with parameters of type TridentCollector

Constructor and Description
ChainedResult(TridentCollector collector, int size)
GroupCollector(TridentCollector collector, ComboList.Factory factory)

Uses of TridentCollector in storm.trident.planner.processor

Classes in storm.trident.planner.processor that implement TridentCollector

Modifier and Type	Class and Description
class	AppendCollector
class	FreshCollector

Uses of TridentCollector in storm.trident.spout

Methods in storm.trident.spout with parameters of type TridentCollector

Modifier and Type	Method and Description
void	IBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	BatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
void	OpaquePartitionedTridentSpoutExecutor.Emitter.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.

Uses of TridentCollector in storm.trident.state

Methods in storm.trident.state with parameters of type TridentCollector

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)

Uses of TridentCollector in storm.trident.state.map

Methods in storm.trident.state.map with parameters of type TridentCollector

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)

Uses of TridentCollector in storm.trident.testing

Methods in storm.trident.testing with parameters of type TridentCollector

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	Split.execute(TridentTuple tuple, TridentCollector collector)
void	TuplifyArgs.execute(TridentTuple input, TridentCollector collector)
void	StringLength.execute(TridentTuple tuple, TridentCollector collector)
storm.trident.testing.CountAsAggregator.State	CountAsAggregator.init(Object batchId, TridentCollector collector)