## Uses of Interface
org.apache.storm.trident.tuple.TridentTuple

- Packages that use TridentTuple
  Package | Description
  --- | ---
  org.apache.storm.cassandra.trident.state |
  org.apache.storm.elasticsearch.trident | ElasticSearch Trident example classes.
  org.apache.storm.hbase.trident |
  org.apache.storm.hbase.trident.mapper |
  org.apache.storm.hbase.trident.state |
  org.apache.storm.hdfs.trident |
  org.apache.storm.hdfs.trident.format |
  org.apache.storm.hdfs.trident.rotation |
  org.apache.storm.hdfs.trident.sync |
  org.apache.storm.hive.bolt.mapper |
  org.apache.storm.hive.trident |
  org.apache.storm.jdbc.trident.state |
  org.apache.storm.jms.trident |
  org.apache.storm.kafka.trident |
  org.apache.storm.kafka.trident.mapper |
  org.apache.storm.kafka.trident.selector |
  org.apache.storm.mongodb.trident |
  org.apache.storm.mongodb.trident.state |
  org.apache.storm.mqtt.trident |
  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.trident |
  org.apache.storm.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 |
  org.apache.storm.trident.planner.processor |
  org.apache.storm.trident.state |
  org.apache.storm.trident.state.map |
  org.apache.storm.trident.testing |
  org.apache.storm.trident.tuple |
  org.apache.storm.trident.windowing |

- - ### Uses of TridentTuple in org.apache.storm.cassandra.trident.state

    Methods in org.apache.storm.cassandra.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | CassandraQuery.`execute(TridentTuple tuple, List<Values> valuesList, TridentCollector collector)`

    Method parameters in org.apache.storm.cassandra.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<List<Values>>` | CassandraQuery.`batchRetrieve(CassandraState state, List<TridentTuple> tridentTuples)`
    `List<List<Values>>` | CassandraState.`batchRetrieve(List<TridentTuple> tridentTuples)`
    `void` | CassandraStateUpdater.`updateState(CassandraState state, List<TridentTuple> list, TridentCollector collector)`
    `void` | CassandraState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.elasticsearch.trident

    Method parameters in org.apache.storm.elasticsearch.trident with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `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 TridentTuple in org.apache.storm.hbase.trident

    Methods in org.apache.storm.hbase.trident with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | PrintFunction.`execute(TridentTuple tuple, TridentCollector tridentCollector)`

  - ### Uses of TridentTuple in org.apache.storm.hbase.trident.mapper

    Methods in org.apache.storm.hbase.trident.mapper with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `ColumnList` | SimpleTridentHBaseMapper.`columns(TridentTuple tuple)`
    `ColumnList` | TridentHBaseMapper.`columns(TridentTuple tuple)` Given a tuple, return a list of HBase columns to insert.
    `byte[]` | SimpleTridentHBaseMapper.`rowKey(TridentTuple tuple)`
    `byte[]` | TridentHBaseMapper.`rowKey(TridentTuple tuple)` Given a tuple, return the HBase rowkey.

  - ### Uses of TridentTuple in org.apache.storm.hbase.trident.state

    Methods in org.apache.storm.hbase.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | HBaseQuery.`execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)`

    Method parameters in org.apache.storm.hbase.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<List<Values>>` | HBaseQuery.`batchRetrieve(HBaseState hBaseState, List<TridentTuple> tridentTuples)`
    `List<List<Values>>` | HBaseState.`batchRetrieve(List<TridentTuple> tridentTuples)`
    `void` | HBaseUpdater.`updateState(HBaseState hBaseState, List<TridentTuple> tuples, TridentCollector collector)`
    `void` | HBaseState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.hdfs.trident

    Method parameters in org.apache.storm.hdfs.trident with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | HdfsState.HdfsFileOptions.`execute(List<TridentTuple> tuples)`
    `void` | HdfsState.SequenceFileOptions.`execute(List<TridentTuple> tuples)`
    `void` | HdfsUpdater.`updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector)`
    `void` | HdfsState.`updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)`

  - ### Uses of TridentTuple in org.apache.storm.hdfs.trident.format

    Methods in org.apache.storm.hdfs.trident.format with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `byte[]` | DelimitedRecordFormat.`format(TridentTuple tuple)`
    `byte[]` | RecordFormat.`format(TridentTuple tuple)`
    `org.apache.hadoop.io.Writable` | DefaultSequenceFormat.`key(TridentTuple tuple)`
    `org.apache.hadoop.io.Writable` | SequenceFormat.`key(TridentTuple tuple)` Given a tuple, return the key that should be written to the sequence file.
    `org.apache.hadoop.io.Writable` | DefaultSequenceFormat.`value(TridentTuple tuple)`
    `org.apache.hadoop.io.Writable` | SequenceFormat.`value(TridentTuple tuple)` Given a tuple, return the value that should be written to the sequence file.

  - ### Uses of TridentTuple in org.apache.storm.hdfs.trident.rotation

    Methods in org.apache.storm.hdfs.trident.rotation with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `boolean` | TimedRotationPolicy.`mark(TridentTuple tuple, long offset)` Called for every tuple the HdfsBolt executes.
    `boolean` | NoRotationPolicy.`mark(TridentTuple tuple, long offset)`
    `boolean` | FileRotationPolicy.`mark(TridentTuple tuple, long offset)` Called for every tuple the HdfsBolt executes.
    `boolean` | FileSizeRotationPolicy.`mark(TridentTuple tuple, long offset)`

  - ### Uses of TridentTuple in org.apache.storm.hdfs.trident.sync

    Methods in org.apache.storm.hdfs.trident.sync with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `boolean` | CountSyncPolicy.`mark(TridentTuple tuple, long offset)`
    `boolean` | SyncPolicy.`mark(TridentTuple tuple, long offset)` Called for every tuple the HdfsBolt executes.

  - ### Uses of TridentTuple in org.apache.storm.hive.bolt.mapper

    Methods in org.apache.storm.hive.bolt.mapper with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<String>` | HiveMapper.`mapPartitions(TridentTuple tuple)` Given a TridetnTuple, return a hive partition values list.
    `List<String>` | DelimitedRecordHiveMapper.`mapPartitions(TridentTuple tuple)`
    `List<String>` | JsonRecordHiveMapper.`mapPartitions(TridentTuple tuple)`
    `byte[]` | HiveMapper.`mapRecord(TridentTuple tuple)` Given a TridentTuple, maps to a HiveRecord based on columnFields.
    `byte[]` | DelimitedRecordHiveMapper.`mapRecord(TridentTuple tuple)`
    `byte[]` | JsonRecordHiveMapper.`mapRecord(TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.hive.trident

    Method parameters in org.apache.storm.hive.trident with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | HiveUpdater.`updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)`
    `void` | HiveState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.jdbc.trident.state

    Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | JdbcQuery.`execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)`

    Method parameters in org.apache.storm.jdbc.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<List<Values>>` | JdbcQuery.`batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)`
    `List<List<Values>>` | JdbcState.`batchRetrieve(List<TridentTuple> tridentTuples)`
    `void` | JdbcUpdater.`updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector)`
    `void` | JdbcState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.jms.trident

    Method parameters in org.apache.storm.jms.trident with type arguments of type TridentTuple
    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 TridentTuple in org.apache.storm.kafka.trident

    Method parameters in org.apache.storm.kafka.trident with type arguments of type TridentTuple
    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 TridentTuple in org.apache.storm.kafka.trident.mapper

    Methods in org.apache.storm.kafka.trident.mapper with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `K` | FieldNameBasedTupleToKafkaMapper.`getKeyFromTuple(TridentTuple tuple)`
    `K` | TridentTupleToKafkaMapper.`getKeyFromTuple(TridentTuple tuple)`
    `V` | FieldNameBasedTupleToKafkaMapper.`getMessageFromTuple(TridentTuple tuple)`
    `V` | TridentTupleToKafkaMapper.`getMessageFromTuple(TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.kafka.trident.selector

    Methods in org.apache.storm.kafka.trident.selector with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `String` | KafkaTopicSelector.`getTopic(TridentTuple tuple)`
    `String` | DefaultTopicSelector.`getTopic(TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.mongodb.trident

    Methods in org.apache.storm.mongodb.trident with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | PrintFunction.`execute(TridentTuple tuple, TridentCollector tridentCollector)`

  - ### Uses of TridentTuple in org.apache.storm.mongodb.trident.state

    Methods in org.apache.storm.mongodb.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | MongoStateQuery.`execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)`

    Method parameters in org.apache.storm.mongodb.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<List<Values>>` | MongoState.`batchRetrieve(List<TridentTuple> tridentTuples)` Batch retrieve values.
    `List<List<Values>>` | MongoStateQuery.`batchRetrieve(MongoState mongoState, List<TridentTuple> tridentTuples)`
    `void` | MongoState.`updateState(List<TridentTuple> tuples, TridentCollector collector)` Update Mongo state.
    `void` | MongoStateUpdater.`updateState(MongoState state, List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.mqtt.trident

    Methods in org.apache.storm.mqtt.trident with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | MqttPublishFunction.`execute(TridentTuple tuple, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.opentsdb.trident

    Method parameters in org.apache.storm.opentsdb.trident with type arguments of type TridentTuple
    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 TridentTuple in org.apache.storm.redis.trident

    Methods in org.apache.storm.redis.trident with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | PrintFunction.`execute(TridentTuple tuple, TridentCollector tridentCollector)`

  - ### Uses of TridentTuple in org.apache.storm.redis.trident.state

    Methods in org.apache.storm.redis.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | AbstractRedisStateQuerier.`execute(TridentTuple tuple, List<Values> values, TridentCollector collector)`

    Method parameters in org.apache.storm.redis.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<List<Values>>` | AbstractRedisStateQuerier.`batchRetrieve(T state, List<TridentTuple> inputs)`
    `void` | AbstractRedisStateUpdater.`updateState(T state, List<TridentTuple> inputs, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.rocketmq.trident.state

    Method parameters in org.apache.storm.rocketmq.trident.state with type arguments of type TridentTuple
    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 TridentTuple in org.apache.storm.solr.trident

    Method parameters in org.apache.storm.solr.trident with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | SolrState.`updateState(List<TridentTuple> tuples)`
    `void` | SolrUpdater.`updateState(SolrState solrState, List<TridentTuple> tuples, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.starter.trident

    Methods in org.apache.storm.starter.trident with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | TridentWordCount.Split.`execute(TridentTuple tuple, TridentCollector collector)`
    `void` | TridentReach.ExpandList.`execute(TridentTuple tuple, TridentCollector collector)`
    `Integer` | TridentReach.One.`init(TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.trident

    Method parameters in org.apache.storm.trident with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `Stream` | Stream.`max(Comparator<TridentTuple> comparator)` This aggregator operation computes the maximum of tuples in a stream by using the given `comparator` with `TridentTuple`s.
    `Stream` | Stream.`min(Comparator<TridentTuple> comparator)` This aggregator operation computes the minimum of tuples in a stream by using the given `comparator` with `TridentTuple`s.

  - ### Uses of TridentTuple in org.apache.storm.trident.drpc

    Methods in org.apache.storm.trident.drpc with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | ReturnResultsReducer.`execute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)`

  - ### Uses of TridentTuple in org.apache.storm.trident.operation

    Methods in org.apache.storm.trident.operation with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | Consumer.`accept(TridentTuple input)` Performs the operation on the input trident tuple.
    `void` | Aggregator.`aggregate(T val, TridentTuple tuple, 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)`
    `Iterable<Values>` | FlatMapFunction.`execute(TridentTuple input)` Invoked by the framework for each trident tuple in a stream.
    `Values` | MapFunction.`execute(TridentTuple input)` Invoked by the framework for each trident tuple in a stream.
    `void` | Function.`execute(TridentTuple tuple, TridentCollector collector)` Performs the function logic on an individual tuple and emits 0 or more tuples.
    `T` | GroupedMultiReducer.`init(TridentCollector collector, TridentTuple group)`
    `T` | CombinerAggregator.`init(TridentTuple tuple)`
    `boolean` | Filter.`isKeep(TridentTuple tuple)` Determines if a tuple should be filtered out of a stream.
    `T` | ReducerAggregator.`reduce(T curr, TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.trident.operation.builtin

    Methods in org.apache.storm.trident.operation.builtin with parameters of type TridentTuple
    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` | 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)`
    `Long` | Count.`init(TridentTuple tuple)`
    `Number` | Sum.`init(TridentTuple tuple)`
    `boolean` | Debug.`isKeep(TridentTuple tuple)`
    `boolean` | Negate.`isKeep(TridentTuple tuple)`
    `boolean` | Equals.`isKeep(TridentTuple tuple)`
    `boolean` | FilterNull.`isKeep(TridentTuple tuple)`
    `protected T` | ComparisonAggregator.`valueFromTuple(TridentTuple tuple)`

    Method parameters in org.apache.storm.trident.operation.builtin with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<Object>` | MapGet.`batchRetrieve(ReadOnlyMapState map, List<TridentTuple> keys)`
    `List<Object>` | SnapshotGet.`batchRetrieve(ReadOnlySnapshottable state, List<TridentTuple> args)`
    `List<Iterator<List<Object>>>` | TupleCollectionGet.`batchRetrieve(State state, List<TridentTuple> args)`

  - ### Uses of TridentTuple in org.apache.storm.trident.operation.impl

    Methods in org.apache.storm.trident.operation.impl that return types with arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `Map<TridentTuple,Object>` | GroupedMultiReducerExecutor.`init(TridentCollector collector)`

    Methods in org.apache.storm.trident.operation.impl with parameters of type TridentTuple
    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` | JoinerMultiReducer.`complete(JoinState state, TridentTuple group, TridentCollector collector)`
    `void` | PreservingFieldsOrderJoinerMultiReducer.`complete(JoinState state, TridentTuple group, 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)`
    `JoinState` | JoinerMultiReducer.`init(TridentCollector collector, TridentTuple group)`
    `JoinState` | PreservingFieldsOrderJoinerMultiReducer.`init(TridentCollector collector, TridentTuple group)`
    `boolean` | TrueFilter.`isKeep(TridentTuple tuple)`

    Method parameters in org.apache.storm.trident.operation.impl with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | GroupedMultiReducerExecutor.`complete(Map<TridentTuple,Object> state, TridentCollector collector)`
    `void` | GroupedMultiReducerExecutor.`execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, 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 TridentTuple
    Constructor and Description
    `JoinState(int numSides, TridentTuple group)`

  - ### Uses of TridentTuple in org.apache.storm.trident.planner

    Methods in org.apache.storm.trident.planner with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | BridgeReceiver.`execute(ProcessorContext context, String streamId, TridentTuple tuple)`
    `void` | TupleReceiver.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.trident.planner.processor

    Methods in org.apache.storm.trident.planner.processor with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | MapProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | AggregateProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | PartitionPersistProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | EachProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | StateQueryProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | ProjectedProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | MultiReducerProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
    `void` | AppendCollector.`setContext(ProcessorContext pc, TridentTuple t)`

  - ### Uses of TridentTuple in org.apache.storm.trident.state

    Methods in org.apache.storm.trident.state with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | QueryFunction.`execute(TridentTuple tuple, T result, TridentCollector collector)`

    Method parameters in org.apache.storm.trident.state with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `List<T>` | QueryFunction.`batchRetrieve(S state, List<TridentTuple> args)`
    `void` | StateUpdater.`updateState(S state, List<TridentTuple> tuples, TridentCollector collector)`

    Constructor parameters in org.apache.storm.trident.state with type arguments of type TridentTuple
    Constructor and Description
    `ReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples)`

  - ### Uses of TridentTuple in org.apache.storm.trident.state.map

    Method parameters in org.apache.storm.trident.state.map with type arguments of type TridentTuple
    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 TridentTuple in org.apache.storm.trident.testing

    Methods in org.apache.storm.trident.testing with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | CountAsAggregator.`aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)`
    `void` | TuplifyArgs.`execute(TridentTuple input, TridentCollector collector)`
    `void` | Split.`execute(TridentTuple tuple, TridentCollector collector)`
    `void` | StringLength.`execute(TridentTuple tuple, TridentCollector collector)`
    `boolean` | TrueFilter.`isKeep(TridentTuple tuple)`

  - ### Uses of TridentTuple in org.apache.storm.trident.tuple

    Classes in org.apache.storm.trident.tuple that implement TridentTuple
    Modifier and Type | Class and Description
    --- | ---
    `class` | `TridentTupleView` Extends AbstractList so that it can be emitted directly as Storm tuples.

    Methods in org.apache.storm.trident.tuple that return TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `TridentTuple` | TridentTupleView.FreshOutputFactory.`create(List<Object> selfVals)`
    `TridentTuple` | TridentTupleView.ProjectionFactory.`create(TridentTuple parent)`
    `TridentTuple` | TridentTupleView.OperationOutputFactory.`create(TridentTupleView parent, List<Object> selfVals)`
    `TridentTuple` | TridentTupleView.RootFactory.`create(Tuple parent)`
    `static TridentTuple` | TridentTupleView.`createFreshTuple(Fields fields, List<Object> values)`
    `static TridentTuple` | TridentTupleView.`createFreshTuple(Fields fields, Object... values)`

    Methods in org.apache.storm.trident.tuple with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `TridentTuple` | TridentTupleView.ProjectionFactory.`create(TridentTuple parent)`

  - ### Uses of TridentTuple in org.apache.storm.trident.windowing

    Methods in org.apache.storm.trident.windowing that return TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `TridentTuple` | StoreBasedTridentWindowManager.`collectTridentTupleOrKey(TridentBatchTuple tridentBatchTuple, List<String> keys)`

    Methods in org.apache.storm.trident.windowing that return types with arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `protected abstract List<TridentTuple>` | AbstractTridentWindowManager.`getTridentTuples(List<T> tupleEvents)` Return `TridentTuple`s from given `tupleEvents`.
    `List<TridentTuple>` | StoreBasedTridentWindowManager.`getTridentTuples(List<TridentBatchTuple> tridentBatchTuples)`
    `List<TridentTuple>` | InMemoryTridentWindowManager.`getTridentTuples(List<TridentTuple> tridentBatchTuples)`

    Methods in org.apache.storm.trident.windowing with parameters of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | WindowTridentProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`

    Method parameters in org.apache.storm.trident.windowing with type arguments of type TridentTuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | InMemoryTridentWindowManager.`addTuplesBatch(Object batchId, List<TridentTuple> tuples)`
    `void` | ITridentWindowManager.`addTuplesBatch(Object batchId, List<TridentTuple> tuples)` Add received batch of tuples to cache/store and add them to `WindowManager`.
    `void` | StoreBasedTridentWindowManager.`addTuplesBatch(Object batchId, List<TridentTuple> tuples)`
    `List<TridentTuple>` | InMemoryTridentWindowManager.`getTridentTuples(List<TridentTuple> tridentBatchTuples)`
    `void` | InMemoryTridentWindowManager.`onTuplesExpired(List<TridentTuple> expiredTuples)`
    `void` | WindowsStateUpdater.`updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)`

    Constructors in org.apache.storm.trident.windowing with parameters of type TridentTuple
    Constructor and Description
    `TridentBatchTuple(String effectiveBatchId, long timeStamp, int tupleIndex, TridentTuple tridentTuple)`

Copyright © 2021 The Apache Software Foundation. All rights reserved.