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	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	WordCountTopology.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	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)