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

Packages that use TridentTuple
Package
Description
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.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.redis.trident
org.apache.storm.redis.trident.state
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.hdfs.trident

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

- ## 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
  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
  Description
  `boolean`
  FileRotationPolicy.`mark(TridentTuple tuple, long offset)`
  Called for every tuple the HdfsBolt executes.
  `boolean`
  FileSizeRotationPolicy.`mark(TridentTuple tuple, long offset)`
  `boolean`
  NoRotationPolicy.`mark(TridentTuple tuple, long offset)`
  `boolean`
  TimedRotationPolicy.`mark(TridentTuple tuple, long offset)`
  Called for every tuple the HdfsBolt executes.

- ## 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
  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.jdbc.trident.state

  Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentTuple
  Modifier and Type
  Method
  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
  Description
  `List<List<Values>>`
  JdbcQuery.`batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)`
  `List<List<Values>>`
  JdbcState.`batchRetrieve(List<TridentTuple> tridentTuples)`
  `void`
  JdbcState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`
  `void`
  JdbcUpdater.`updateState(JdbcState jdbcState, 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
  Description
  `void`
  JmsState.`updateState(List<TridentTuple> tuples, TridentCollector collector)`
  `void`
  JmsUpdater.`updateState(JmsState jmsState, 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
  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
  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
  Description
  `String`
  DefaultTopicSelector.`getTopic(TridentTuple tuple)`
  `String`
  KafkaTopicSelector.`getTopic(TridentTuple tuple)`

- ## 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
  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
  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
  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.starter.trident

  Methods in org.apache.storm.starter.trident with parameters of type TridentTuple
  Modifier and Type
  Method
  Description
  `void`
  TridentReach.ExpandList.`execute(TridentTuple tuple, TridentCollector collector)`
  `void`
  TridentWordCount.Split.`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
  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
  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
  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)`
  `Iterable<Values>`
  FlatMapFunction.`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.
  `void`
  GroupedMultiReducer.`execute(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)`
  `Values`
  MapFunction.`execute(TridentTuple input)`
  Invoked by the framework for each trident tuple in a stream.
  `void`
  MultiReducer.`execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)`
  `T`
  CombinerAggregator.`init(TridentTuple tuple)`
  `T`
  GroupedMultiReducer.`init(TridentCollector collector, TridentTuple group)`
  `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
  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`
  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)`
  `Long`
  Count.`init(TridentTuple tuple)`
  `Number`
  Sum.`init(TridentTuple tuple)`
  `boolean`
  Debug.`isKeep(TridentTuple tuple)`
  `boolean`
  Equals.`isKeep(TridentTuple tuple)`
  `boolean`
  FilterNull.`isKeep(TridentTuple tuple)`
  `boolean`
  Negate.`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
  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
  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
  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`
  JoinerMultiReducer.`complete(JoinState state, TridentTuple group, TridentCollector collector)`
  `void`
  PreservingFieldsOrderJoinerMultiReducer.`complete(JoinState state, TridentTuple group, 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)`
  `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
  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
  Modifier
  Constructor
  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
  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
  Description
  `void`
  AggregateProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  EachProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  MapProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  MultiReducerProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  PartitionPersistProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  ProjectedProcessor.`execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)`
  `void`
  StateQueryProcessor.`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
  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
  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
  Modifier
  Constructor
  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
  Description
  `void`
  MapCombinerAggStateUpdater.`updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)`
  `void`
  MapReducerAggStateUpdater.`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
  Description
  `void`
  CountAsAggregator.`aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)`
  `void`
  Split.`execute(TridentTuple tuple, TridentCollector collector)`
  `void`
  StringLength.`execute(TridentTuple tuple, TridentCollector collector)`
  `void`
  TuplifyArgs.`execute(TridentTuple input, 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
  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
  Description
  `TridentTuple`
  TridentTupleView.FreshOutputFactory.`create(List<Object> selfVals)`
  `TridentTuple`
  TridentTupleView.OperationOutputFactory.`create(TridentTupleView parent, List<Object> selfVals)`
  `TridentTuple`
  TridentTupleView.ProjectionFactory.`create(TridentTuple parent)`
  `TridentTuple`
  TridentTupleView.RootFactory.`create(Tuple parent)`
  `static TridentTuple`
  TridentTupleView.`createFreshTuple(Fields fields, Object... values)`
  `static TridentTuple`
  TridentTupleView.`createFreshTuple(Fields fields, List<Object> values)`
  Methods in org.apache.storm.trident.tuple with parameters of type TridentTuple
  Modifier and Type
  Method
  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
  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
  Description
  `protected abstract List<TridentTuple>`
  AbstractTridentWindowManager.`getTridentTuples(List<T> tupleEvents)`
  Return `TridentTuple`s from given `tupleEvents`.
  `List<TridentTuple>`
  InMemoryTridentWindowManager.`getTridentTuples(List<TridentTuple> tridentBatchTuples)`
  `List<TridentTuple>`
  StoreBasedTridentWindowManager.`getTridentTuples(List<TridentBatchTuple> tridentBatchTuples)`
  Methods in org.apache.storm.trident.windowing with parameters of type TridentTuple
  Modifier and Type
  Method
  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
  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
  Modifier
  Constructor
  Description
  ``
  `TridentBatchTuple(String effectiveBatchId, long timeStamp, int tupleIndex, TridentTuple tridentTuple)`