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

Packages that use TridentCollector

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.eventhubs.trident
org.apache.storm.hbase.trident
org.apache.storm.hbase.trident.state
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.mongodb.trident
org.apache.storm.mongodb.trident.state
org.apache.storm.mqtt.trident
org.apache.storm.opentsdb
org.apache.storm.opentsdb.trident
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.rocketmq.trident.state
org.apache.storm.solr.trident
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.cassandra.trident.state

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

Modifier and Type	Method and Description
void	CassandraQuery.execute(TridentTuple tuple, List<Values> valuesList, TridentCollector collector)
void	CassandraStateUpdater.updateState(CassandraState state, List<TridentTuple> list, TridentCollector collector)
void	CassandraState.updateState(List<TridentTuple> tuples, TridentCollector collector)

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 and 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.eventhubs.trident

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

Modifier and Type	Method and Description
Map	OpaqueTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)
void	TransactionalTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)
Map<String,Object>	TransactionalTridentEventHubEmitter.emitPartitionBatchNew(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)

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

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

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

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

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

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)

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 and Description
void	FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	HdfsUpdater.updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector)
void	HdfsState.updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)

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 and Description
void	TridentHiveTopology.FixedBatchSpout.emitBatch(long batchId, TridentCollector collector)
void	HiveUpdater.updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)
void	HiveState.updateState(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 and Description
void	JdbcQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
void	JdbcUpdater.updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector)
void	JdbcState.updateState(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 and Description
void	JmsUpdater.updateState(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector)
void	JmsState.updateState(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 and 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 and 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.mongodb.trident

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

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

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

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

Modifier and Type	Method and Description
void	MongoStateQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
void	MongoState.updateState(List<TridentTuple> tuples, TridentCollector collector) Update Mongo state.
void	MongoStateUpdater.updateState(MongoState state, List<TridentTuple> tuples, TridentCollector collector)

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

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

Modifier and Type	Method and Description
void	MqttPublishFunction.execute(TridentTuple tuple, TridentCollector collector)

Uses of TridentCollector in org.apache.storm.opentsdb

Methods in org.apache.storm.opentsdb with parameters of type TridentCollector

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

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

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

Modifier and Type	Method and Description
void	OpenTsdbState.update(List<TridentTuple> tridentTuples, TridentCollector collector)
void	OpenTsdbStateUpdater.updateState(OpenTsdbState 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 and 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 and 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.rocketmq.trident.state

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

Modifier and Type	Method and Description
void	RocketMqState.updateState(List<TridentTuple> tuples, TridentCollector collector) Update the RocketMQ state.
void	RocketMqStateUpdater.updateState(RocketMqState state, List<TridentTuple> tuples, TridentCollector collector)

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

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

Modifier and Type	Method and Description
void	SolrUpdater.updateState(SolrState solrState, List<TridentTuple> tuples, 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 and 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 and Description
void	TridentWordCount.Split.execute(TridentTuple tuple, TridentCollector collector)
void	TridentReach.ExpandList.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 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 org.apache.storm.trident.operation

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

Modifier and Type	Method and Description
void	Aggregator.aggregate(T val, TridentTuple tuple, TridentCollector collector)
void	Aggregator.complete(T val, TridentCollector collector)
void	MultiReducer.complete(T state, 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) Performs the function logic on an individual tuple and emits 0 or more tuples.
T	Aggregator.init(Object batchId, TridentCollector collector)
T	MultiReducer.init(TridentCollector collector)
T	GroupedMultiReducer.init(TridentCollector collector, TridentTuple group)

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 and 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	TupleCollectionGet.execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector)
void	MapGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	SnapshotGet.execute(TridentTuple tuple, Object result, 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)
ComparisonAggregator.State	ComparisonAggregator.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 and Description
class	CaptureCollector
class	GroupCollector

Methods in org.apache.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(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)
void	ChainedAggregatorImpl.complete(ChainedResult val, TridentCollector collector)
void	JoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state, TridentCollector collector)
void	GroupedAggregator.complete(Object[] arr, TridentCollector collector)
void	ReducerAggregatorImpl.complete(Result val, TridentCollector collector)
void	CombinerAggregatorCombineImpl.complete(Result val, TridentCollector collector)
void	SingleEmitAggregator.complete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentCollector collector)
void	IdentityMultiReducer.complete(T state, TridentCollector collector)
void	JoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.execute(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(T state, int streamIndex, TridentTuple input, TridentCollector collector)
void	CombinerAggregatorInitImpl.execute(TridentTuple tuple, TridentCollector collector)
void	FilterExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FlatMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	ConsumerExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	MapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
Result	ReducerAggregatorImpl.init(Object batchId, TridentCollector collector)
Result	CombinerAggregatorCombineImpl.init(Object batchId, TridentCollector collector)
org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState	SingleEmitAggregator.init(Object batchId, TridentCollector collector)
ChainedResult	ChainedAggregatorImpl.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)
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

Constructor and 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 and 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 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, 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 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 org.apache.storm.trident.state.map

Methods in org.apache.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 org.apache.storm.trident.testing

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

Modifier and Type	Method and 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	TuplifyArgs.execute(TridentTuple input, TridentCollector collector)
void	Split.execute(TridentTuple tuple, TridentCollector collector)
void	StringLength.execute(TridentTuple tuple, 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 and Description
void	WindowsStateUpdater.updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)