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

- Packages that use TridentCollector
  Package | Description
  --- | ---
  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.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)` | Deprecated, for removal: This API element is subject to removal in a future version.
    `void` | HiveUpdater.`updateState​(HiveState state, List<TridentTuple> tuples, TridentCollector collector)` | Deprecated, for removal: This API element is subject to removal in a future version.

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