Uses of Interface
org.apache.storm.trident.operation.TridentCollector

Packages that use TridentCollector

Package	Description
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.hdfs.trident
org.apache.storm.hive.trident
org.apache.storm.jdbc.trident.state
org.apache.storm.jms.trident
org.apache.storm.kafka.spout.trident
org.apache.storm.kafka.trident
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.starter.spout
org.apache.storm.starter.trident
org.apache.storm.trident.drpc
org.apache.storm.trident.operation
org.apache.storm.trident.operation.builtin
org.apache.storm.trident.operation.impl
org.apache.storm.trident.planner.processor
org.apache.storm.trident.spout
org.apache.storm.trident.state
org.apache.storm.trident.state.map
org.apache.storm.trident.testing
org.apache.storm.trident.windowing

Uses of TridentCollector in org.apache.storm.elasticsearch.trident

Methods in org.apache.storm.elasticsearch.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	TridentEsTopology.FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)	Emits a batch.
void	EsUpdater.updateState(org.apache.storm.elasticsearch.trident.EsState state, List<TridentTuple> tuples, TridentCollector collector)	Each tuple should have relevant fields (source, index, type, id) for EsState's tupleMapper to extract ES document.

Uses of TridentCollector in org.apache.storm.hdfs.trident

Methods in org.apache.storm.hdfs.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	HdfsState.updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)
void	HdfsUpdater.updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.hive.trident

Methods in org.apache.storm.hive.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	TridentHiveTopology.FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	HiveState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	HiveUpdater.updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.jdbc.trident.state

Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentCollector

Modifier and Type	Method	Description
void	JdbcQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
void	JdbcState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	JdbcUpdater.updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.jms.trident

Methods in org.apache.storm.jms.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	JmsState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	JmsUpdater.updateState(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.kafka.spout.trident

Methods in org.apache.storm.kafka.spout.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
Map<String,Object>	KafkaTridentOpaqueSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> lastPartitionMeta)
void	KafkaTridentTransactionalSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> partitionMeta)
Map<String,Object>	KafkaTridentSpoutEmitter.emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> lastBatch)	Emit a new batch.
Map<String,Object>	KafkaTridentTransactionalSpoutEmitter.emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> lastPartitionMeta)
void	KafkaTridentSpoutEmitter.reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> currBatch)	Emit a batch that has already been emitted.

Uses of TridentCollector in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	TridentKafkaState.updateState(List<TridentTuple> tuples, TridentCollector collector)	Write the given tuples to Kafka.
void	TridentKafkaStateUpdater.updateState(TridentKafkaState<K,V> state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.redis.trident

Methods in org.apache.storm.redis.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	PrintFunction.execute(TridentTuple tuple, TridentCollector tridentCollector)

Uses of TridentCollector in org.apache.storm.redis.trident.state

Methods in org.apache.storm.redis.trident.state with parameters of type TridentCollector

Modifier and Type	Method	Description
void	AbstractRedisStateQuerier.execute(TridentTuple tuple, List<Values> values, TridentCollector collector)
void	AbstractRedisStateUpdater.updateState(T state, List<TridentTuple> inputs, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.starter.spout

Methods in org.apache.storm.starter.spout with parameters of type TridentCollector

Modifier and Type	Method	Description
void	RandomNumberGeneratorSpout.emitBatch(long batchId, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.starter.trident

Methods in org.apache.storm.starter.trident with parameters of type TridentCollector

Modifier and Type	Method	Description
void	TridentReach.ExpandList.execute(TridentTuple tuple, TridentCollector collector)
void	TridentWordCount.Split.execute(TridentTuple tuple, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.trident.drpc

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

Modifier and Type	Method	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 org.apache.storm.trident.operation

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

Modifier and Type	Method	Description
void	Aggregator.aggregate(T val, TridentTuple tuple, TridentCollector collector)
void	Aggregator.complete(T val, TridentCollector collector)
void	GroupedMultiReducer.complete(T state, TridentTuple group, TridentCollector collector)
void	MultiReducer.complete(T state, TridentCollector collector)
void	Function.execute(TridentTuple tuple, TridentCollector collector)	Performs the function logic on an individual tuple and emits 0 or more tuples.
void	GroupedMultiReducer.execute(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
void	MultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
T	Aggregator.init(Object batchId, TridentCollector collector)
T	GroupedMultiReducer.init(TridentCollector collector, TridentTuple group)
T	MultiReducer.init(TridentCollector collector)

Uses of TridentCollector in org.apache.storm.trident.operation.builtin

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

Modifier and Type	Method	Description
void	ComparisonAggregator.aggregate(ComparisonAggregator.State state, TridentTuple tuple, TridentCollector collector)
void	FirstN.FirstNAgg.aggregate(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentTuple tuple, TridentCollector collector)
void	FirstN.FirstNSortedAgg.aggregate(PriorityQueue state, TridentTuple tuple, TridentCollector collector)
void	ComparisonAggregator.complete(ComparisonAggregator.State state, TridentCollector collector)
void	FirstN.FirstNAgg.complete(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentCollector collector)
void	FirstN.FirstNSortedAgg.complete(PriorityQueue val, TridentCollector collector)
void	MapGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	SnapshotGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	TupleCollectionGet.execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector)
ComparisonAggregator.State	ComparisonAggregator.init(Object batchId, TridentCollector collector)
org.apache.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 org.apache.storm.trident.operation.impl

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

Modifier and Type	Class	Description
class	CaptureCollector
class	GroupCollector

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

Modifier and Type	Method	Description
void	ChainedAggregatorImpl.aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector)
void	CombinerAggregatorCombineImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	GroupedAggregator.aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector)
void	ReducerAggregatorImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	SingleEmitAggregator.aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)
void	ChainedAggregatorImpl.complete(ChainedResult val, TridentCollector collector)
void	CombinerAggregatorCombineImpl.complete(Result val, TridentCollector collector)
void	GroupedAggregator.complete(Object[] arr, TridentCollector collector)
void	GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state, TridentCollector collector)
void	IdentityMultiReducer.complete(T state, TridentCollector collector)
void	JoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	ReducerAggregatorImpl.complete(Result val, TridentCollector collector)
void	SingleEmitAggregator.complete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector)
void	CombinerAggregatorInitImpl.execute(TridentTuple tuple, TridentCollector collector)
void	ConsumerExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FilterExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FlatMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
void	IdentityMultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
void	JoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
void	MapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
ChainedResult	ChainedAggregatorImpl.init(Object batchId, TridentCollector collector)
Result	CombinerAggregatorCombineImpl.init(Object batchId, TridentCollector collector)
Object[]	GroupedAggregator.init(Object batchId, TridentCollector collector)
Map<TridentTuple,Object>	GroupedMultiReducerExecutor.init(TridentCollector collector)
T	IdentityMultiReducer.init(TridentCollector collector)
JoinState	JoinerMultiReducer.init(TridentCollector collector, TridentTuple group)
JoinState	PreservingFieldsOrderJoinerMultiReducer.init(TridentCollector collector, TridentTuple group)
Result	ReducerAggregatorImpl.init(Object batchId, TridentCollector collector)
org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState	SingleEmitAggregator.init(Object batchId, TridentCollector collector)
void	CaptureCollector.setCollector(TridentCollector coll)
void	ChainedResult.setFollowThroughCollector(TridentCollector collector)
void	CombinerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)
void	ReducerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)

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

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

Uses of TridentCollector in org.apache.storm.trident.planner.processor

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

Modifier and Type	Class	Description
class	AppendCollector
class	FreshCollector

Uses of TridentCollector in org.apache.storm.trident.spout

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

Modifier and Type	Method	Description
void	BatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
void	IBatchSpout.emitBatch(long batchId, 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.
void	OpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
M	IOpaquePartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, PartitionT partition, M lastPartitionMeta)	Emit a batch of tuples for a partition/transaction.
void	IPartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, PartitionT 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, PartitionT partition, X lastPartitionMeta)	Emit a batch of tuples for a partition/transaction that's never been emitted before.

Uses of TridentCollector in org.apache.storm.trident.state

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

Modifier and Type	Method	Description
void	QueryFunction.execute(TridentTuple tuple, T result, TridentCollector collector)
void	StateUpdater.updateState(S state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.trident.state.map

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

Modifier and Type	Method	Description
void	MapCombinerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)
void	MapReducerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.trident.testing

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

Modifier and Type	Method	Description
void	CountAsAggregator.aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)
void	CountAsAggregator.complete(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentCollector collector)
void	FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	Split.execute(TridentTuple tuple, TridentCollector collector)
void	StringLength.execute(TridentTuple tuple, TridentCollector collector)
void	TuplifyArgs.execute(TridentTuple input, TridentCollector collector)
org.apache.storm.trident.testing.CountAsAggregator.State	CountAsAggregator.init(Object batchId, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.trident.windowing

Methods in org.apache.storm.trident.windowing with parameters of type TridentCollector

Modifier and Type	Method	Description
void	WindowsStateUpdater.updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)