# Uses of Interface
org.apache.storm.tuple.Tuple

Packages that use Tuple
Package
Description
org.apache.storm
org.apache.storm.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.drpc
org.apache.storm.executor.bolt
org.apache.storm.flux.examples
org.apache.storm.flux.wrappers.bolts
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.bolt.format
org.apache.storm.hdfs.bolt.rotation
org.apache.storm.hdfs.bolt.sync
org.apache.storm.hdfs.common
org.apache.storm.hdfs.spout
org.apache.storm.hooks.info
org.apache.storm.jdbc.bolt
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.kafka.bolt
org.apache.storm.kafka.bolt.mapper
org.apache.storm.kafka.bolt.selector
org.apache.storm.kafka.spout
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.metric
org.apache.storm.perf
org.apache.storm.perf.bolt
org.apache.storm.perf.utils
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
org.apache.storm.serialization
org.apache.storm.spout
org.apache.storm.sql.runtime.datasource.socket.bolt
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.st.topology.window.data
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.starter.tools
org.apache.storm.state
org.apache.storm.streams
org.apache.storm.streams.operations.mappers
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident.planner
org.apache.storm.trident.spout
org.apache.storm.trident.topology
org.apache.storm.trident.tuple
org.apache.storm.tuple
org.apache.storm.utils
org.apache.storm.windowing

- ## Uses of Tuple in org.apache.storm

  Methods in org.apache.storm that return Tuple
  Modifier and Type
  Method
  Description
  `static Tuple`
  Testing.`testTuple(List<Object> values)`
  Create a `Tuple` for use with testing.
  `static Tuple`
  Testing.`testTuple(List<Object> values, MkTupleParam param)`
  Create a `Tuple` for use with testing.
  Methods in org.apache.storm with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  ExclamationTopology.ExclamationBolt.`execute(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.bolt

  Methods in org.apache.storm.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `protected Object`
  JoinBolt.`lookupField(JoinBolt.FieldSelector fieldSelector, Tuple tuple)`
  Method parameters in org.apache.storm.bolt with type arguments of type Tuple
  Modifier and Type
  Method
  Description
  `protected JoinBolt.JoinAccumulator`
  JoinBolt.`doInnerJoin(JoinBolt.JoinAccumulator probe, Map<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)`
  `protected JoinBolt.JoinAccumulator`
  JoinBolt.`doJoin(JoinBolt.JoinAccumulator probe, HashMap<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)`
  `protected JoinBolt.JoinAccumulator`
  JoinBolt.`doLeftJoin(JoinBolt.JoinAccumulator probe, Map<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)`
  `protected ArrayList<Object>`
  JoinBolt.`doProjection(ArrayList<Tuple> tuples, JoinBolt.FieldSelector[] projectionFields)`
  `protected JoinBolt.JoinAccumulator`
  JoinBolt.`hashJoin(List<Tuple> tuples)`
  Constructors in org.apache.storm.bolt with parameters of type Tuple
  Modifier
  Constructor
  Description
  ``
  `ResultRecord(JoinBolt.ResultRecord lhs, Tuple rhs, boolean generateOutputFields)`
  ``
  `ResultRecord(Tuple tuple, boolean generateOutputFields)`

- ## Uses of Tuple in org.apache.storm.clojure

  Classes in org.apache.storm.clojure that implement Tuple
  Modifier and Type
  Class
  Description
  `class`
  `ClojureTuple`
  Methods in org.apache.storm.clojure with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  ClojureBolt.`execute(Tuple input)`
  Constructors in org.apache.storm.clojure with parameters of type Tuple
  Modifier
  Constructor
  Description
  ``
  `ClojureTuple(Tuple t)`

- ## Uses of Tuple in org.apache.storm.coordination

  Methods in org.apache.storm.coordination with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  BatchOutputCollectorImpl.`ack(Tuple tup)`
  `void`
  CoordinatedBolt.CoordinatedOutputCollector.`ack(Tuple tuple)`
  `void`
  BatchBoltExecutor.`execute(Tuple input)`
  `void`
  CoordinatedBolt.`execute(Tuple tuple)`
  `void`
  IBatchBolt.`execute(Tuple tuple)`
  `void`
  BatchOutputCollectorImpl.`fail(Tuple tup)`
  `void`
  CoordinatedBolt.CoordinatedOutputCollector.`fail(Tuple tuple)`
  `void`
  CoordinatedBolt.CoordinatedOutputCollector.`resetTimeout(Tuple tuple)`
  Method parameters in org.apache.storm.coordination with type arguments of type Tuple
  Modifier and Type
  Method
  Description
  `List<Integer>`
  CoordinatedBolt.CoordinatedOutputCollector.`emit(String stream, Collection<Tuple> anchors, List<Object> tuple)`
  `void`
  CoordinatedBolt.CoordinatedOutputCollector.`emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)`

- ## Uses of Tuple in org.apache.storm.daemon

  Methods in org.apache.storm.daemon that return Tuple
  Modifier and Type
  Method
  Description
  `Tuple`
  Task.`getTuple(String stream, List values)`
  Methods in org.apache.storm.daemon with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  Acker.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.drpc

  Methods in org.apache.storm.drpc with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  JoinResult.`execute(Tuple tuple)`
  `void`
  KeyedFairBolt.`execute(Tuple input)`
  `void`
  PrepareRequest.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ReturnResults.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.executor.bolt

  Methods in org.apache.storm.executor.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  BoltOutputCollectorImpl.`ack(Tuple input)`
  `void`
  BoltOutputCollectorImpl.`fail(Tuple input)`
  `void`
  BoltOutputCollectorImpl.`resetTimeout(Tuple input)`
  Method parameters in org.apache.storm.executor.bolt with type arguments of type Tuple
  Modifier and Type
  Method
  Description
  `List<Integer>`
  BoltOutputCollectorImpl.`emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)`
  `void`
  BoltOutputCollectorImpl.`emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)`

- ## Uses of Tuple in org.apache.storm.flux.examples

  Methods in org.apache.storm.flux.examples with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  StatefulWordCounter.`execute(Tuple tuple)`
  `void`
  TestPrintBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  WordCounter.`execute(Tuple input, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.flux.wrappers.bolts

  Methods in org.apache.storm.flux.wrappers.bolts with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  LogInfoBolt.`execute(Tuple tuple, BasicOutputCollector basicOutputCollector)`

- ## Uses of Tuple in org.apache.storm.hdfs.bolt

  Methods in org.apache.storm.hdfs.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `final void`
  AbstractHdfsBolt.`execute(Tuple tuple)`
  `void`
  HdfsFileTopology.MyBolt.`execute(Tuple tuple)`
  `void`
  SequenceFileTopology.MyBolt.`execute(Tuple tuple)`
  `protected org.apache.hadoop.fs.Path`
  AbstractHdfsBolt.`getBasePathForNextFile(Tuple tuple)`
  `protected abstract String`
  AbstractHdfsBolt.`getWriterKey(Tuple tuple)`
  `protected String`
  AvroGenericRecordBolt.`getWriterKey(Tuple tuple)`
  AvroGenericRecordBolt must override this method because messages with different schemas cannot be written to the same file.
  `protected String`
  HdfsBolt.`getWriterKey(Tuple tuple)`
  `protected String`
  SequenceFileBolt.`getWriterKey(Tuple tuple)`
  `protected abstract Writer`
  AbstractHdfsBolt.`makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)`
  `protected AbstractHDFSWriter`
  AvroGenericRecordBolt.`makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)`
  `protected AbstractHDFSWriter`
  HdfsBolt.`makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)`
  `protected AbstractHDFSWriter`
  SequenceFileBolt.`makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)`
  `long`
  Writer.`write(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.hdfs.bolt.format

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

- ## Uses of Tuple in org.apache.storm.hdfs.bolt.rotation

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

- ## Uses of Tuple in org.apache.storm.hdfs.bolt.sync

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

- ## Uses of Tuple in org.apache.storm.hdfs.common

  Methods in org.apache.storm.hdfs.common with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `protected abstract void`
  AbstractHDFSWriter.`doWrite(Tuple tuple)`
  `protected void`
  AvroGenericRecordHDFSWriter.`doWrite(Tuple tuple)`
  `protected void`
  HDFSWriter.`doWrite(Tuple tuple)`
  `protected void`
  SequenceFileWriter.`doWrite(Tuple tuple)`
  `String`
  NullPartitioner.`getPartitionPath(Tuple tuple)`
  `String`
  Partitioner.`getPartitionPath(Tuple tuple)`
  Return a relative path that the tuple should be written to.
  `final long`
  AbstractHDFSWriter.`write(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.hdfs.spout

  Methods in org.apache.storm.hdfs.spout with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  HdfsSpoutTopology.ConstBolt.`execute(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.hooks.info

  Fields in org.apache.storm.hooks.info declared as Tuple
  Modifier and Type
  Field
  Description
  `Tuple`
  BoltAckInfo.`tuple`
  `Tuple`
  BoltExecuteInfo.`tuple`
  `Tuple`
  BoltFailInfo.`tuple`
  Constructors in org.apache.storm.hooks.info with parameters of type Tuple
  Modifier
  Constructor
  Description
  ``
  `BoltAckInfo(Tuple tuple, int ackingTaskId, Long processLatencyMs)`
  ``
  `BoltExecuteInfo(Tuple tuple, int executingTaskId, Long executeLatencyMs)`
  ``
  `BoltFailInfo(Tuple tuple, int failingTaskId, Long failLatencyMs)`

- ## Uses of Tuple in org.apache.storm.jdbc.bolt

  Methods in org.apache.storm.jdbc.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `protected void`
  JdbcInsertBolt.`process(Tuple tuple)`
  `protected void`
  JdbcLookupBolt.`process(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.jms.bolt

  Methods in org.apache.storm.jms.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `protected void`
  JmsBolt.`process(Tuple input)`
  Consumes a tuple and sends a JMS message.

- ## Uses of Tuple in org.apache.storm.jms.example

  Methods in org.apache.storm.jms.example with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  GenericBolt.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.kafka.bolt

  Methods in org.apache.storm.kafka.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `protected void`
  KafkaBolt.`process(Tuple input)`

- ## Uses of Tuple in org.apache.storm.kafka.bolt.mapper

  Methods in org.apache.storm.kafka.bolt.mapper with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `K`
  FieldNameBasedTupleToKafkaMapper.`getKeyFromTuple(Tuple tuple)`
  `K`
  TupleToKafkaMapper.`getKeyFromTuple(Tuple tuple)`
  `V`
  FieldNameBasedTupleToKafkaMapper.`getMessageFromTuple(Tuple tuple)`
  `V`
  TupleToKafkaMapper.`getMessageFromTuple(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.kafka.bolt.selector

  Methods in org.apache.storm.kafka.bolt.selector with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `String`
  DefaultTopicSelector.`getTopic(Tuple tuple)`
  `String`
  FieldIndexTopicSelector.`getTopic(Tuple tuple)`
  `String`
  FieldNameTopicSelector.`getTopic(Tuple tuple)`
  `String`
  KafkaTopicSelector.`getTopic(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.kafka.spout

  Methods in org.apache.storm.kafka.spout with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  KafkaSpoutTestBolt.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.lambda

  Methods in org.apache.storm.lambda with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  LambdaBiConsumerBolt.`execute(Tuple input, BasicOutputCollector collector)`
  `void`
  LambdaConsumerBolt.`execute(Tuple input, BasicOutputCollector collector)`
  Constructor parameters in org.apache.storm.lambda with type arguments of type Tuple
  Modifier
  Constructor
  Description
  ``
  `LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String[] fields)`
  ``
  `LambdaConsumerBolt(SerializableConsumer<Tuple> consumer)`

- ## Uses of Tuple in org.apache.storm.loadgen

  Methods in org.apache.storm.loadgen with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  LoadBolt.`execute(Tuple input)`
  `void`
  ThroughputVsLatency.SplitSentence.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ThroughputVsLatency.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.metric

  Methods in org.apache.storm.metric with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  EventLoggerBolt.`execute(Tuple input)`
  `void`
  MetricsConsumerBolt.`execute(Tuple input)`
  `void`
  SystemBolt.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.perf

  Methods in org.apache.storm.perf with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `byte[]`
  KafkaClientHdfsTopo.LineWriter.`format(Tuple tuple)`
  `byte[]`
  StrGenSpoutHdfsBoltTopo.LineWriter.`format(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.perf.bolt

  Methods in org.apache.storm.perf.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  CountBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  DevNullBolt.`execute(Tuple tuple)`
  `void`
  IdBolt.`execute(Tuple tuple)`
  `void`
  SplitSentenceBolt.`execute(Tuple input, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.perf.utils

  Methods in org.apache.storm.perf.utils with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  IdentityBolt.`execute(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.redis.bolt

  Methods in org.apache.storm.redis.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  RedisFilterBolt.`process(Tuple input)`
  Process a single non-tick tuple of input.
  `void`
  RedisLookupBolt.`process(Tuple input)`
  Process a single non-tick tuple of input.
  `void`
  RedisStoreBolt.`process(Tuple input)`
  Process a single non-tick tuple of input.

- ## Uses of Tuple in org.apache.storm.redis.topology

  Methods in org.apache.storm.redis.topology with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  LookupWordCount.PrintWordTotalCountBolt.`execute(Tuple input)`
  `void`
  WhitelistWordCount.PrintWordTotalCountBolt.`execute(Tuple input)`
  `void`
  WordCounter.`execute(Tuple input, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.serialization

  Methods in org.apache.storm.serialization that return Tuple
  Modifier and Type
  Method
  Description
  `Tuple`
  ITupleDeserializer.`deserialize(byte[] ser)`
  Methods in org.apache.storm.serialization with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `byte[]`
  ITupleSerializer.`serialize(Tuple tuple)`
  `byte[]`
  KryoTupleSerializer.`serialize(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.spout

  Methods in org.apache.storm.spout with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `static boolean`
  CheckpointSpout.`isCheckpoint(Tuple input)`

- ## Uses of Tuple in org.apache.storm.sql.runtime.datasource.socket.bolt

  Methods in org.apache.storm.sql.runtime.datasource.socket.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  SocketBolt.`execute(Tuple input)`

- ## Uses of Tuple in org.apache.storm.sql.runtime.streams.functions

  Methods in org.apache.storm.sql.runtime.streams.functions with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `Values`
  StreamsScanTupleValueMapper.`apply(Tuple input)`

- ## Uses of Tuple in org.apache.storm.st.topology.window.data

  Methods in org.apache.storm.st.topology.window.data with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `static TimeData`
  TimeData.`fromTuple(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.starter

  Methods in org.apache.storm.starter with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  AnchoredWordCount.SplitSentence.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  AnchoredWordCount.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  BasicDRPCTopology.ExclaimBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  BlobStoreAPIWordCountTopology.FilterWords.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ExclamationTopology.ExclamationBolt.`execute(Tuple tuple)`
  `void`
  FastWordCountTopology.SplitSentence.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  FastWordCountTopology.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  InOrderDeliveryTest.Check.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ManualDRPC.ExclamationBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  MultipleLoggerTopology.ExclamationLoggingBolt.`execute(Tuple tuple)`
  `void`
  MultiThreadWordCountTopology.MultiThreadedSplitSentence.`execute(Tuple input)`
  `void`
  ReachTopology.CountAggregator.`execute(Tuple tuple)`
  `void`
  ReachTopology.GetFollowers.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ReachTopology.GetTweeters.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  ReachTopology.PartialUniquer.`execute(Tuple tuple)`
  `void`
  ResourceAwareExampleTopology.ExclamationBolt.`execute(Tuple tuple)`
  `void`
  StatefulTopology.PrinterBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  WordCountTopologyNode.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.starter.bolt

  Methods in org.apache.storm.starter.bolt with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `final void`
  AbstractRankerBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  This method functions as a template method (design pattern).
  `void`
  PrinterBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  RollingCountAggBolt.`execute(Tuple tuple)`
  `void`
  RollingCountBolt.`execute(Tuple tuple)`
  `void`
  SingleJoinBolt.`execute(Tuple tuple)`
  `void`
  WordCountBolt.`execute(Tuple tuple, BasicOutputCollector collector)`

- ## Uses of Tuple in org.apache.storm.starter.tools

  Methods in org.apache.storm.starter.tools with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `static RankableObjectWithFields`
  RankableObjectWithFields.`from(Tuple tuple)`
  Construct a new instance based on the provided `Tuple`.

- ## Uses of Tuple in org.apache.storm.state

  Methods in org.apache.storm.state with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  ISubscribedState.`set(Object id, Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.streams

  Methods in org.apache.storm.streams that return Tuple
  Modifier and Type
  Method
  Description
  `Tuple`
  RefCountedTuple.`tuple()`
  Methods in org.apache.storm.streams that return types with arguments of type Tuple
  Modifier and Type
  Method
  Description
  `Stream<Tuple>`
  StreamBuilder.`newStream(IRichSpout spout)`
  Creates a new `Stream` of tuples from the given `IRichSpout`.
  `Stream<Tuple>`
  StreamBuilder.`newStream(IRichSpout spout, int parallelism)`
  Creates a new `Stream` of tuples from the given `IRichSpout` with the given parallelism.

- ## Uses of Tuple in org.apache.storm.streams.operations.mappers

  Methods in org.apache.storm.streams.operations.mappers with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `Pair<K,V>`
  PairValueMapper.`apply(Tuple input)`
  `T`
  ValueMapper.`apply(Tuple input)`
  `Values`
  ValuesMapper.`apply(Tuple input)`

- ## Uses of Tuple in org.apache.storm.task

  Methods in org.apache.storm.task with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  IOutputCollector.`ack(Tuple input)`
  `void`
  OutputCollector.`ack(Tuple input)`
  `List<Integer>`
  OutputCollector.`emit(String streamId, Tuple anchor, List<Object> tuple)`
  Emits a new tuple to a specific stream with a single anchor.
  `List<Integer>`
  OutputCollector.`emit(Tuple anchor, List<Object> tuple)`
  Emits a new tuple to the default stream anchored on a single tuple.
  `void`
  OutputCollector.`emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple)`
  Emits a tuple directly to the specified task id on the specified stream.
  `void`
  OutputCollector.`emitDirect(int taskId, Tuple anchor, List<Object> tuple)`
  Emits a tuple directly to the specified task id on the default stream.
  `void`
  IBolt.`execute(Tuple input)`
  Process a single tuple of input.
  `void`
  ShellBolt.`execute(Tuple input)`
  `void`
  IOutputCollector.`fail(Tuple input)`
  `void`
  OutputCollector.`fail(Tuple input)`
  `void`
  IOutputCollector.`resetTimeout(Tuple input)`
  `void`
  OutputCollector.`resetTimeout(Tuple input)`
  Resets the message timeout for any tuple trees to which the given tuple belongs.
  Method parameters in org.apache.storm.task with type arguments of type Tuple
  Modifier and Type
  Method
  Description
  `List<Integer>`
  IOutputCollector.`emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)`
  Returns the task ids that received the tuples.
  `List<Integer>`
  OutputCollector.`emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)`
  `List<Integer>`
  OutputCollector.`emit(Collection<Tuple> anchors, List<Object> tuple)`
  Emits a new tuple to the default stream anchored on a group of input tuples.
  `void`
  IOutputCollector.`emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)`
  `void`
  OutputCollector.`emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)`
  `void`
  OutputCollector.`emitDirect(int taskId, Collection<Tuple> anchors, List<Object> tuple)`
  Emits a tuple directly to the specified task id on the default stream.

- ## Uses of Tuple in org.apache.storm.testing

  Methods in org.apache.storm.testing with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  IdentityBolt.`execute(Tuple input, BasicOutputCollector collector)`
  `void`
  NonRichBoltTracker.`execute(Tuple input)`
  `void`
  PrepareBatchBolt.`execute(Tuple input, BasicOutputCollector collector)`
  `void`
  TestAggregatesCounter.`execute(Tuple input)`
  `void`
  TestConfBolt.`execute(Tuple input, BasicOutputCollector collector)`
  `void`
  TestEventOrderCheckBolt.`execute(Tuple input)`
  `void`
  TestGlobalCount.`execute(Tuple input)`
  `void`
  TestPlannerBolt.`execute(Tuple input)`
  `void`
  TestWordCounter.`execute(Tuple input, BasicOutputCollector collector)`
  `void`
  TupleCaptureBolt.`execute(Tuple input)`
  `protected String`
  TestWordBytesCounter.`getTupleValue(Tuple t, int idx)`
  `protected String`
  TestWordCounter.`getTupleValue(Tuple t, int idx)`

- ## Uses of Tuple in org.apache.storm.topology

  Methods in org.apache.storm.topology that return types with arguments of type Tuple
  Modifier and Type
  Method
  Description
  `protected WindowLifecycleListener<Tuple>`
  PersistentWindowedBoltExecutor.`newWindowLifecycleListener()`
  `protected WindowLifecycleListener<Tuple>`
  StatefulWindowedBoltExecutor.`newWindowLifecycleListener()`
  `protected WindowLifecycleListener<Tuple>`
  WindowedBoltExecutor.`newWindowLifecycleListener()`
  Methods in org.apache.storm.topology with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  BaseStatefulBoltExecutor.`execute(Tuple input)`
  `void`
  BasicBoltExecutor.`execute(Tuple input)`
  `void`
  IBasicBolt.`execute(Tuple input, BasicOutputCollector collector)`
  Process the input tuple and optionally emit new tuples based on the input tuple.
  `void`
  IStatefulBolt.`execute(Tuple input)`
  Analogue to bolt function.
  `void`
  PersistentWindowedBoltExecutor.`execute(Tuple input)`
  `void`
  StatefulWindowedBoltExecutor.`execute(Tuple input)`
  `void`
  WindowedBoltExecutor.`execute(Tuple input)`
  `long`
  TupleFieldTimestampExtractor.`extractTimestamp(Tuple tuple)`
  `protected abstract void`
  BaseStatefulBoltExecutor.`handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)`
  Sub-classes can implement the logic for handling checkpoint tuple.
  `protected void`
  CheckpointTupleForwarder.`handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)`
  Forwards the checkpoint tuple downstream.
  `protected void`
  StatefulBoltExecutor.`handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)`
  `protected abstract void`
  BaseStatefulBoltExecutor.`handleTuple(Tuple input)`
  Sub-classes can implement the logic for handling the tuple.
  `protected void`
  CheckpointTupleForwarder.`handleTuple(Tuple input)`
  Hands off tuple to the wrapped bolt to execute.
  `protected void`
  StatefulBoltExecutor.`handleTuple(Tuple input)`
  `void`
  BasicOutputCollector.`resetTimeout(Tuple tuple)`
  Resets the message timeout for any tuple trees to which the given tuple belongs.
  `void`
  IBasicOutputCollector.`resetTimeout(Tuple tuple)`
  `void`
  BasicOutputCollector.`setContext(Tuple inputTuple)`
  Method parameters in org.apache.storm.topology with type arguments of type Tuple
  Modifier and Type
  Method
  Description
  `protected void`
  WindowedBoltExecutor.`boltExecute(Supplier<Iterator<Tuple>> tuples, Supplier<Iterator<Tuple>> newTuples, Supplier<Iterator<Tuple>> expiredTuples, Long timestamp)`
  `protected void`
  WindowedBoltExecutor.`boltExecute(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long timestamp)`
  `protected void`
  WindowedBoltExecutor.`doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)`
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, Number parallelismHint, String... fields)`
  Define a new bolt in this topology.
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String... fields)`
  Define a new bolt in this topology.
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, SerializableConsumer<Tuple> consumer)`
  Define a new bolt in this topology.
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, SerializableConsumer<Tuple> consumer, Number parallelismHint)`
  Define a new bolt in this topology.

- ## Uses of Tuple in org.apache.storm.topology.base

  Methods in org.apache.storm.topology.base with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  BaseTickTupleAwareRichBolt.`execute(Tuple tuple)`
  Process a single tuple of input.
  `protected void`
  BaseTickTupleAwareRichBolt.`onTickTuple(Tuple tuple)`
  Process a single tick tuple of input.
  `protected abstract void`
  BaseTickTupleAwareRichBolt.`process(Tuple tuple)`
  Process a single non-tick tuple of input.

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

  Methods in org.apache.storm.trident.planner with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  SubtopologyBolt.`execute(BatchInfo batchInfo, Tuple tuple)`
  `void`
  SubtopologyBolt.InitialReceiver.`receive(ProcessorContext context, Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.trident.spout

  Methods in org.apache.storm.trident.spout with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  TridentSpoutCoordinator.`execute(Tuple tuple, BasicOutputCollector collector)`
  `void`
  TridentSpoutExecutor.`execute(BatchInfo info, Tuple input)`

- ## Uses of Tuple in org.apache.storm.trident.topology

  Methods in org.apache.storm.trident.topology with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  ITridentBatchBolt.`execute(BatchInfo batchInfo, Tuple tuple)`
  `void`
  TridentBoltExecutor.`execute(Tuple tuple)`

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

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

- ## Uses of Tuple in org.apache.storm.tuple

  Classes in org.apache.storm.tuple that implement Tuple
  Modifier and Type
  Class
  Description
  `class`
  `TupleImpl`
  Fields in org.apache.storm.tuple declared as Tuple
  Modifier and Type
  Field
  Description
  `final Tuple`
  AddressedTuple.`tuple`
  Methods in org.apache.storm.tuple that return Tuple
  Modifier and Type
  Method
  Description
  `Tuple`
  AddressedTuple.`getTuple()`
  Constructors in org.apache.storm.tuple with parameters of type Tuple
  Modifier
  Constructor
  Description
  ``
  `AddressedTuple(int dest, Tuple tuple)`
  ``
  `TupleImpl(Tuple t)`

- ## Uses of Tuple in org.apache.storm.utils

  Methods in org.apache.storm.utils that return types with arguments of type Tuple
  Modifier and Type
  Method
  Description
  `List<Tuple>`
  BatchHelper.`getBatchTuples()`
  Methods in org.apache.storm.utils with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `void`
  BatchHelper.`addBatch(Tuple tuple)`
  `static boolean`
  TupleUtils.`isTick(Tuple tuple)`
  `boolean`
  BatchHelper.`shouldHandle(Tuple tuple)`

- ## Uses of Tuple in org.apache.storm.windowing

  Methods in org.apache.storm.windowing that return types with arguments of type Tuple
  Modifier and Type
  Method
  Description
  `List<Tuple>`
  TupleWindowImpl.`get()`
  `List<Tuple>`
  TupleWindowIterImpl.`get()`
  `List<Tuple>`
  TupleWindowImpl.`getExpired()`
  `List<Tuple>`
  TupleWindowIterImpl.`getExpired()`
  `Iterator<Tuple>`
  TupleWindowIterImpl.`getIter()`
  `List<Tuple>`
  TupleWindowImpl.`getNew()`
  `List<Tuple>`
  TupleWindowIterImpl.`getNew()`
  Methods in org.apache.storm.windowing with parameters of type Tuple
  Modifier and Type
  Method
  Description
  `long`
  TimestampExtractor.`extractTimestamp(Tuple tuple)`
  Return the tuple timestamp indicating the time when the event happened.
  Constructor parameters in org.apache.storm.windowing with type arguments of type Tuple
  Modifier
  Constructor
  Description
  ``
  `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)`
  ``
  `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long startTimestamp, Long endTimestamp)`
  ``
  `TupleWindowIterImpl(Supplier<Iterator<Tuple>> tuplesIt, Supplier<Iterator<Tuple>> newTuplesIt, Supplier<Iterator<Tuple>> expiredTuplesIt, Long startTimestamp, Long endTimestamp)`