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

- Packages that use Tuple
  Package | Description
  --- | ---
  org.apache.storm |
  org.apache.storm.bolt |
  org.apache.storm.cassandra |
  org.apache.storm.cassandra.bolt |
  org.apache.storm.cassandra.executor |
  org.apache.storm.cassandra.executor.impl |
  org.apache.storm.clojure |
  org.apache.storm.coordination |
  org.apache.storm.daemon |
  org.apache.storm.drpc |
  org.apache.storm.elasticsearch.bolt | ElasticSearch examples classes.
  org.apache.storm.elasticsearch.common | Shared code for example classes.
  org.apache.storm.eventhubs.bolt |
  org.apache.storm.executor.bolt |
  org.apache.storm.flux.examples |
  org.apache.storm.flux.wrappers.bolts |
  org.apache.storm.hbase.bolt |
  org.apache.storm.hbase.bolt.mapper |
  org.apache.storm.hbase.topology |
  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.hive.bolt |
  org.apache.storm.hive.bolt.mapper |
  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.mongodb.bolt |
  org.apache.storm.mongodb.topology |
  org.apache.storm.mqtt.bolt |
  org.apache.storm.opentsdb.bolt |
  org.apache.storm.perf |
  org.apache.storm.perf.bolt |
  org.apache.storm.perf.utils |
  org.apache.storm.pmml |
  org.apache.storm.pmml.runner |
  org.apache.storm.pmml.runner.jpmml |
  org.apache.storm.redis.bolt |
  org.apache.storm.redis.topology |
  org.apache.storm.rocketmq.bolt |
  org.apache.storm.rocketmq.topology |
  org.apache.storm.serialization |
  org.apache.storm.solr.bolt |
  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 and 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 and 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 and 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 and 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
    Constructor and Description
    `ResultRecord(JoinBolt.ResultRecord lhs, Tuple rhs, boolean generateOutputFields)`
    `ResultRecord(Tuple tuple, boolean generateOutputFields)`

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

    Methods in org.apache.storm.cassandra with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `protected void` | BaseExecutionResultHandler.`onDriverException(com.datastax.driver.core.exceptions.DriverException e, OutputCollector collector, Tuple tuple)` This method is called when an one of the methods of the `BaseExecutionResultHandler` is not overridden.
    `void` | BaseExecutionResultHandler.`onQuerySuccess(OutputCollector collector, Tuple tuple)` Invoked when a query is executed with success.
    `void` | ExecutionResultHandler.`onQuerySuccess(OutputCollector collector, Tuple tuple)` Invoked when a query is executed with success.
    `void` | BaseExecutionResultHandler.`onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple)` Invoked when a `QueryValidationException` is thrown.
    `void` | ExecutionResultHandler.`onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple)` Invoked when a `QueryValidationException` is thrown.
    `void` | BaseExecutionResultHandler.`onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple)` Invoked when a `ReadTimeoutException` is thrown.
    `void` | ExecutionResultHandler.`onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple)` Invoked when a `ReadTimeoutException` is thrown.
    `void` | AbstractExecutionResultHandler.`onThrowable(Throwable t, OutputCollector collector, Tuple i)`
    `void` | ExecutionResultHandler.`onThrowable(Throwable t, OutputCollector collector, Tuple i)` Default method used to handle any type of exception.
    `void` | BaseExecutionResultHandler.`onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple)` Invoked when a `UnavailableException` is thrown.
    `void` | ExecutionResultHandler.`onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple)` Invoked when a `UnavailableException` is thrown.
    `void` | BaseExecutionResultHandler.`onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple)` Invoked when a `WriteTimeoutException` is thrown.
    `void` | ExecutionResultHandler.`onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple)` Invoked when a `WriteTimeoutException` is thrown.

    Method parameters in org.apache.storm.cassandra with type arguments of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | AbstractExecutionResultHandler.`onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl)`
    `void` | ExecutionResultHandler.`onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl)` Default method used to handle any type of exception.

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

    Methods in org.apache.storm.cassandra.bolt that return Tuple
    Modifier and Type | Method and Description
    --- | ---
    `Tuple` | PairStatementTuple.`getTuple()`

    Methods in org.apache.storm.cassandra.bolt that return types with arguments of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `protected AsyncResultHandler<Tuple>` | CassandraWriterBolt.`getAsyncHandler()`
    `protected AsyncResultHandler<List<Tuple>>` | BatchCassandraWriterBolt.`getAsyncHandler()`
    `List<Tuple>` | PairBatchStatementTuples.`getInputs()`

    Methods in org.apache.storm.cassandra.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | BaseCassandraBolt.`execute(Tuple input)` Process a single tuple of input.
    `protected void` | BatchCassandraWriterBolt.`onTickTuple(Tuple tuple)` Process a single tick tuple of input.
    `protected void` | CassandraWriterBolt.`process(Tuple input)` Process a single non-tick tuple of input.
    `protected void` | BatchCassandraWriterBolt.`process(Tuple input)` Process a single non-tick tuple of input.

    Constructors in org.apache.storm.cassandra.bolt with parameters of type Tuple
    Constructor and Description
    `PairStatementTuple(Tuple tuple, com.datastax.driver.core.Statement statement)` Creates a new `PairStatementTuple` instance.

    Constructor parameters in org.apache.storm.cassandra.bolt with type arguments of type Tuple
    Constructor and Description
    `PairBatchStatementTuples(List<Tuple> inputs, com.datastax.driver.core.BatchStatement statement)` Creates a new `PairBatchStatementTuples` instance.

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

    Constructors in org.apache.storm.cassandra.executor with parameters of type Tuple
    Constructor and Description
    `FailedCollector(Tuple input, Throwable cause)` Creates a new `ExecutionResultCollector.FailedCollector` instance.
    `SucceedCollector(Tuple input)` Creates a new `ExecutionResultCollector` instance.

    Constructor parameters in org.apache.storm.cassandra.executor with type arguments of type Tuple
    Constructor and Description
    `FailedCollector(List<Tuple> inputs, Throwable cause)` Creates a new `ExecutionResultCollector.FailedCollector` instance.
    `SucceedCollector(List<Tuple> inputs)` Creates a new `ExecutionResultCollector` instance.

  - ### Uses of Tuple in org.apache.storm.cassandra.executor.impl

    Methods in org.apache.storm.cassandra.executor.impl with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | SingleAsyncResultHandler.`failure(Throwable t, Tuple input)` This method is responsible for failing specified inputs.
    `void` | SingleAsyncResultHandler.`success(Tuple input)` This method is responsible for acknowledging specified inputs.

    Method parameters in org.apache.storm.cassandra.executor.impl with type arguments of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | BatchAsyncResultHandler.`failure(Throwable t, List<Tuple> input)` This method is responsible for failing specified inputs.
    `void` | BatchAsyncResultHandler.`success(List<Tuple> input)` This method is responsible for acknowledging specified inputs.

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

    Classes in org.apache.storm.clojure that implement Tuple
    Modifier and Type | Class and Description
    --- | ---
    `class` | `ClojureTuple`

    Methods in org.apache.storm.clojure with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | ClojureBolt.`execute(Tuple input)`

    Constructors in org.apache.storm.clojure with parameters of type Tuple
    Constructor and 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 and Description
    --- | ---
    `void` | CoordinatedBolt.CoordinatedOutputCollector.`ack(Tuple tuple)`
    `void` | BatchOutputCollectorImpl.`ack(Tuple tup)`
    `void` | CoordinatedBolt.`execute(Tuple tuple)`
    `void` | IBatchBolt.`execute(Tuple tuple)`
    `void` | BatchBoltExecutor.`execute(Tuple input)`
    `void` | CoordinatedBolt.CoordinatedOutputCollector.`fail(Tuple tuple)`
    `void` | BatchOutputCollectorImpl.`fail(Tuple tup)`
    `void` | CoordinatedBolt.CoordinatedOutputCollector.`resetTimeout(Tuple tuple)`

    Method parameters in org.apache.storm.coordination with type arguments of type Tuple
    Modifier and Type | Method and 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 and Description
    --- | ---
    `Tuple` | Task.`getTuple(String stream, List values)`

    Methods in org.apache.storm.daemon with parameters of type Tuple
    Modifier and Type | Method and 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 and Description
    --- | ---
    `void` | KeyedFairBolt.`execute(Tuple input)`
    `void` | ReturnResults.`execute(Tuple input)`
    `void` | JoinResult.`execute(Tuple tuple)`
    `void` | PrepareRequest.`execute(Tuple tuple, BasicOutputCollector collector)`

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

    Methods in org.apache.storm.elasticsearch.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | EsLookupBolt.`process(Tuple tuple)`
    `void` | EsIndexBolt.`process(Tuple tuple)` Process a single non-tick tuple of input.
    `void` | EsPercolateBolt.`process(Tuple tuple)` Process a single non-tick tuple of input.

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

    Methods in org.apache.storm.elasticsearch.common that return Tuple
    Modifier and Type | Method and Description
    --- | ---
    `static Tuple` | EsTestUtil.`generateTestTuple(String source, String index, String type, String id)` Generates a test tuple.

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

    Methods in org.apache.storm.eventhubs.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | EventHubBolt.`execute(Tuple tuple)`
    `byte[]` | DefaultEventDataFormat.`serialize(Tuple tuple)`
    `byte[]` | IEventDataFormat.`serialize(Tuple tuple)`

  - ### 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 and 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 and 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 and Description
    --- | ---
    `void` | StatefulWordCounter.`execute(Tuple tuple)`
    `void` | WordCounter.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | TestPrintBolt.`execute(Tuple tuple, 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 and Description
    --- | ---
    `void` | LogInfoBolt.`execute(Tuple tuple, BasicOutputCollector basicOutputCollector)`

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

    Methods in org.apache.storm.hbase.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | HBaseBolt.`execute(Tuple tuple)`
    `void` | HBaseLookupBolt.`execute(Tuple tuple)`

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

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

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

    Methods in org.apache.storm.hbase.topology with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | WordCounter.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | TotalWordCounter.`execute(Tuple input, BasicOutputCollector collector)`

  - ### 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 and Description
    --- | ---
    `void` | SequenceFileTopology.MyBolt.`execute(Tuple tuple)`
    `void` | HdfsFileTopology.MyBolt.`execute(Tuple tuple)`
    `void` | AbstractHdfsBolt.`execute(Tuple tuple)`
    `protected org.apache.hadoop.fs.Path` | AbstractHdfsBolt.`getBasePathForNextFile(Tuple tuple)`
    `protected String` | HdfsBolt.`getWriterKey(Tuple tuple)`
    `protected String` | SequenceFileBolt.`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 abstract String` | AbstractHdfsBolt.`getWriterKey(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)`
    `protected AbstractHDFSWriter` | AvroGenericRecordBolt.`makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)`
    `protected abstract Writer` | AbstractHdfsBolt.`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 and 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 and Description
    --- | ---
    `boolean` | TimedRotationPolicy.`mark(Tuple tuple, long offset)` Called for every tuple the HdfsBolt executes.
    `boolean` | NoRotationPolicy.`mark(Tuple tuple, long offset)`
    `boolean` | FileRotationPolicy.`mark(Tuple tuple, long offset)` Called for every tuple the HdfsBolt executes.
    `boolean` | FileSizeRotationPolicy.`mark(Tuple tuple, long offset)`

  - ### 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 and 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 and Description
    --- | ---
    `protected void` | AvroGenericRecordHDFSWriter.`doWrite(Tuple tuple)`
    `protected abstract void` | AbstractHDFSWriter.`doWrite(Tuple tuple)`
    `protected void` | SequenceFileWriter.`doWrite(Tuple tuple)`
    `protected void` | HDFSWriter.`doWrite(Tuple tuple)`
    `String` | NullPartitioner.`getPartitionPath(Tuple tuple)`
    `String` | Partitioner.`getPartitionPath(Tuple tuple)` Return a relative path that the tuple should be written to.
    `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 and Description
    --- | ---
    `void` | HdfsSpoutTopology.ConstBolt.`execute(Tuple tuple)`

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

    Methods in org.apache.storm.hive.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | HiveBolt.`execute(Tuple tuple)`

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

    Methods in org.apache.storm.hive.bolt.mapper with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `List<String>` | HiveMapper.`mapPartitions(Tuple tuple)` Given a tuple, return a hive partition values list.
    `List<String>` | DelimitedRecordHiveMapper.`mapPartitions(Tuple tuple)`
    `List<String>` | JsonRecordHiveMapper.`mapPartitions(Tuple tuple)`
    `byte[]` | HiveMapper.`mapRecord(Tuple tuple)` Given a tuple, maps to a HiveRecord based on columnFields.
    `byte[]` | DelimitedRecordHiveMapper.`mapRecord(Tuple tuple)`
    `byte[]` | JsonRecordHiveMapper.`mapRecord(Tuple tuple)`
    `void` | HiveMapper.`write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)`
    `void` | DelimitedRecordHiveMapper.`write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)`
    `void` | JsonRecordHiveMapper.`write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, 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 and Description
    --- | ---
    `Tuple` | BoltAckInfo.`tuple`
    `Tuple` | BoltExecuteInfo.`tuple`
    `Tuple` | BoltFailInfo.`tuple`

    Constructors in org.apache.storm.hooks.info with parameters of type Tuple
    Constructor and 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 and Description
    --- | ---
    `protected void` | JdbcLookupBolt.`process(Tuple tuple)`
    `protected void` | JdbcInsertBolt.`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 and 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 and 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 and 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 and 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 and Description
    --- | ---
    `String` | KafkaTopicSelector.`getTopic(Tuple tuple)`
    `String` | FieldNameTopicSelector.`getTopic(Tuple tuple)`
    `String` | FieldIndexTopicSelector.`getTopic(Tuple tuple)`
    `String` | DefaultTopicSelector.`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 and 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 and 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
    Constructor and 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 and 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 and Description
    --- | ---
    `void` | MetricsConsumerBolt.`execute(Tuple input)`
    `void` | SystemBolt.`execute(Tuple input)`
    `void` | EventLoggerBolt.`execute(Tuple input)`

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

    Methods in org.apache.storm.mongodb.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | MongoLookupBolt.`execute(Tuple tuple)`
    `void` | MongoInsertBolt.`execute(Tuple tuple)`
    `void` | MongoUpdateBolt.`execute(Tuple tuple)`

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

    Methods in org.apache.storm.mongodb.topology with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | WordCounter.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | TotalWordCounter.`execute(Tuple input, BasicOutputCollector collector)`

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

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

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

    Methods in org.apache.storm.opentsdb.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | OpenTsdbBolt.`execute(Tuple tuple)`

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

    Methods in org.apache.storm.perf with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `byte[]` | StrGenSpoutHdfsBoltTopo.LineWriter.`format(Tuple tuple)`
    `byte[]` | KafkaClientHdfsTopo.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 and Description
    --- | ---
    `void` | IdBolt.`execute(Tuple tuple)`
    `void` | DevNullBolt.`execute(Tuple tuple)`
    `void` | CountBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `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 and Description
    --- | ---
    `void` | IdentityBolt.`execute(Tuple tuple)`

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

    Methods in org.apache.storm.pmml with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `protected void` | PMMLPredictorBolt.`process(Tuple input)`

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

    Methods in org.apache.storm.pmml.runner with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `Map<String,List<Object>>` | ModelRunner.`scoredTuplePerStream(Tuple input)` Creates and returns a map with the predicted scores that are to be emitted on each stream.

  - ### Uses of Tuple in org.apache.storm.pmml.runner.jpmml

    Methods in org.apache.storm.pmml.runner.jpmml with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `Map<org.dmg.pmml.FieldName,Object>` | JPmmlModelRunner.`extractRawInputs(Tuple tuple)` Extract raw inputs.
    `Map<String,List<Object>>` | JPmmlModelRunner.`scoredTuplePerStream(Tuple input)` Retrieve scores.

  - ### 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 and 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 and Description
    --- | ---
    `void` | WhitelistWordCount.PrintWordTotalCountBolt.`execute(Tuple input)`
    `void` | LookupWordCount.PrintWordTotalCountBolt.`execute(Tuple input)`
    `void` | WordCounter.`execute(Tuple input, BasicOutputCollector collector)`

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

    Methods in org.apache.storm.rocketmq.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | RocketMqBolt.`execute(Tuple input)`

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

    Methods in org.apache.storm.rocketmq.topology with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `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 and Description
    --- | ---
    `Tuple` | ITupleDeserializer.`deserialize(byte[] ser)`

    Methods in org.apache.storm.serialization with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `byte[]` | ITupleSerializer.`serialize(Tuple tuple)`
    `byte[]` | KryoTupleSerializer.`serialize(Tuple tuple)`

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

    Methods in org.apache.storm.solr.bolt with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `protected void` | SolrUpdateBolt.`process(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 and 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 and 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 and 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 and 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 and Description
    --- | ---
    `void` | ResourceAwareExampleTopology.ExclamationBolt.`execute(Tuple tuple)`
    `void` | MultiThreadWordCountTopology.MultiThreadedSplitSentence.`execute(Tuple input)`
    `void` | MultipleLoggerTopology.ExclamationLoggingBolt.`execute(Tuple tuple)`
    `void` | ReachTopology.PartialUniquer.`execute(Tuple tuple)`
    `void` | ReachTopology.CountAggregator.`execute(Tuple tuple)`
    `void` | ExclamationTopology.ExclamationBolt.`execute(Tuple tuple)`
    `void` | ManualDRPC.ExclamationBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | AnchoredWordCount.SplitSentence.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | AnchoredWordCount.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | StatefulTopology.PrinterBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | FastWordCountTopology.SplitSentence.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | FastWordCountTopology.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | BasicDRPCTopology.ExclaimBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | WordCountTopologyNode.WordCount.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | InOrderDeliveryTest.Check.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | ReachTopology.GetTweeters.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | ReachTopology.GetFollowers.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | BlobStoreAPIWordCountTopology.FilterWords.`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 and Description
    --- | ---
    `void` | RollingCountAggBolt.`execute(Tuple tuple)`
    `void` | RollingCountBolt.`execute(Tuple tuple)`
    `void` | SingleJoinBolt.`execute(Tuple tuple)`
    `void` | PrinterBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | WordCountBolt.`execute(Tuple tuple, BasicOutputCollector collector)`
    `void` | AbstractRankerBolt.`execute(Tuple tuple, BasicOutputCollector collector)` This method functions as a template method (design pattern).

  - ### 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 and 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 and 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 and Description
    --- | ---
    `Tuple` | RefCountedTuple.`tuple()`

    Methods in org.apache.storm.streams that return types with arguments of type Tuple
    Modifier and Type | Method and 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 and Description
    --- | ---
    `Values` | ValuesMapper.`apply(Tuple input)`
    `Pair<K,V>` | PairValueMapper.`apply(Tuple input)`
    `T` | ValueMapper.`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 and Description
    --- | ---
    `void` | OutputCollector.`ack(Tuple input)`
    `void` | IOutputCollector.`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` | ShellBolt.`execute(Tuple input)`
    `void` | IBolt.`execute(Tuple input)` Process a single tuple of input.
    `void` | OutputCollector.`fail(Tuple input)`
    `void` | IOutputCollector.`fail(Tuple input)`
    `void` | OutputCollector.`resetTimeout(Tuple input)` Resets the message timeout for any tuple trees to which the given tuple belongs.
    `void` | IOutputCollector.`resetTimeout(Tuple input)`

    Method parameters in org.apache.storm.task with type arguments of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `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.
    `List<Integer>` | OutputCollector.`emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)`
    `List<Integer>` | IOutputCollector.`emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)` Returns the task ids that received the tuples.
    `void` | OutputCollector.`emitDirect(int taskId, Collection<Tuple> anchors, List<Object> tuple)` Emits a tuple directly to the specified task id on the default stream.
    `void` | OutputCollector.`emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)`
    `void` | IOutputCollector.`emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)`

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

    Methods in org.apache.storm.testing with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | TupleCaptureBolt.`execute(Tuple input)`
    `void` | NonRichBoltTracker.`execute(Tuple input)`
    `void` | TestPlannerBolt.`execute(Tuple input)`
    `void` | TestAggregatesCounter.`execute(Tuple input)`
    `void` | TestGlobalCount.`execute(Tuple input)`
    `void` | TestEventOrderCheckBolt.`execute(Tuple input)`
    `void` | TestConfBolt.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | PrepareBatchBolt.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | IdentityBolt.`execute(Tuple input, BasicOutputCollector collector)`
    `void` | TestWordCounter.`execute(Tuple input, BasicOutputCollector collector)`
    `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 and Description
    --- | ---
    `protected WindowLifecycleListener<Tuple>` | StatefulWindowedBoltExecutor.`newWindowLifecycleListener()`
    `protected WindowLifecycleListener<Tuple>` | PersistentWindowedBoltExecutor.`newWindowLifecycleListener()`
    `protected WindowLifecycleListener<Tuple>` | WindowedBoltExecutor.`newWindowLifecycleListener()`

    Methods in org.apache.storm.topology with parameters of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `void` | BaseStatefulBoltExecutor.`execute(Tuple input)`
    `void` | StatefulWindowedBoltExecutor.`execute(Tuple input)`
    `void` | IStatefulBolt.`execute(Tuple input)` Analogue to bolt function.
    `void` | PersistentWindowedBoltExecutor.`execute(Tuple input)`
    `void` | BasicBoltExecutor.`execute(Tuple input)`
    `void` | WindowedBoltExecutor.`execute(Tuple input)`
    `void` | IBasicBolt.`execute(Tuple input, BasicOutputCollector collector)` Process the input tuple and optionally emit new tuples based on the input tuple.
    `long` | TupleFieldTimestampExtractor.`extractTimestamp(Tuple tuple)`
    `protected void` | StatefulBoltExecutor.`handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)`
    `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.`handleTuple(Tuple input)`
    `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.
    `void` | IBasicOutputCollector.`resetTimeout(Tuple tuple)`
    `void` | BasicOutputCollector.`resetTimeout(Tuple tuple)` Resets the message timeout for any tuple trees to which the given tuple belongs.
    `void` | BasicOutputCollector.`setContext(Tuple inputTuple)`

    Method parameters in org.apache.storm.topology with type arguments of type Tuple
    Modifier and Type | Method and Description
    --- | ---
    `protected void` | WindowedBoltExecutor.`boltExecute(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long timestamp)`
    `protected void` | WindowedBoltExecutor.`boltExecute(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long timestamp)`
    `protected void` | WindowedBoltExecutor.`boltExecute(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long timestamp)`
    `protected void` | WindowedBoltExecutor.`boltExecute(Supplier<Iterator<Tuple>> tuples, Supplier<Iterator<Tuple>> newTuples, Supplier<Iterator<Tuple>> expiredTuples, Long timestamp)`
    `protected void` | WindowedBoltExecutor.`boltExecute(Supplier<Iterator<Tuple>> tuples, Supplier<Iterator<Tuple>> newTuples, Supplier<Iterator<Tuple>> expiredTuples, Long timestamp)`
    `protected void` | WindowedBoltExecutor.`boltExecute(Supplier<Iterator<Tuple>> tuples, Supplier<Iterator<Tuple>> newTuples, Supplier<Iterator<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 and 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 and 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 and Description
    --- | ---
    `void` | TridentSpoutExecutor.`execute(BatchInfo info, Tuple input)`
    `void` | TridentSpoutCoordinator.`execute(Tuple tuple, BasicOutputCollector collector)`

  - ### 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 and 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 and 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 and Description
    --- | ---
    `class` | `TupleImpl`

    Fields in org.apache.storm.tuple declared as Tuple
    Modifier and Type | Field and Description
    --- | ---
    `Tuple` | AddressedTuple.`tuple`

    Methods in org.apache.storm.tuple that return Tuple
    Modifier and Type | Method and Description
    --- | ---
    `Tuple` | AddressedTuple.`getTuple()`

    Constructors in org.apache.storm.tuple with parameters of type Tuple
    Constructor and 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 and Description
    --- | ---
    `List<Tuple>` | BatchHelper.`getBatchTuples()`

    Methods in org.apache.storm.utils with parameters of type Tuple
    Modifier and Type | Method and 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 and 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 and 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
    Constructor and Description
    `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)`
    `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)`
    `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)`
    `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long startTimestamp, Long endTimestamp)`
    `TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long startTimestamp, Long endTimestamp)`
    `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)`
    `TupleWindowIterImpl(Supplier<Iterator<Tuple>> tuplesIt, Supplier<Iterator<Tuple>> newTuplesIt, Supplier<Iterator<Tuple>> expiredTuplesIt, Long startTimestamp, Long endTimestamp)`
    `TupleWindowIterImpl(Supplier<Iterator<Tuple>> tuplesIt, Supplier<Iterator<Tuple>> newTuplesIt, Supplier<Iterator<Tuple>> expiredTuplesIt, Long startTimestamp, Long endTimestamp)`

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