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

Packages that use TridentCollector
Package
Description
org.apache.storm.hdfs.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.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.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<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentOpaqueSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  Emit a new batch.
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentTransactionalSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastPartitionMetaMap)`
  `void`
  KafkaTridentSpoutEmitter.`reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> currBatch)`
  Emit a batch that has already been emitted.
  `void`
  KafkaTridentTransactionalSpoutEmitter.`reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> partitionMeta)`

- ## 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)`
  `Map<PartitionT,M>`
  IOpaquePartitionedTridentSpout.Emitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,M> lastBatchMetaMap)`
  Emit a batch of tuples for a list of partitions/transactions.
  `Map<PartitionT,X>`
  IPartitionedTridentSpout.Emitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,X> lastPartitionMetaMap)`
  Emit a batch of tuples for the partitions that's never been emitted before.
  `void`
  IPartitionedTridentSpout.Emitter.`reEmitPartitionBatch(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.

- ## 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)`