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

Packages that use Tuple

Package	Description
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.drpc
org.apache.storm.druid.bolt
org.apache.storm.elasticsearch.bolt
org.apache.storm.elasticsearch.common
org.apache.storm.eventhubs.bolt
org.apache.storm.eventhubs.samples.bolt
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.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.serialization
org.apache.storm.solr.bolt
org.apache.storm.spout
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.starter.tools
org.apache.storm.state
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.transactional
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
storm.starter

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	ExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	BaseExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	ExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	BaseExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	ExecutionResultHandler.onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a ReadTimeoutException is thrown.
void	BaseExecutionResultHandler.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	ExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	BaseExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	ExecutionResultHandler.onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a WriteTimeoutException is thrown.
void	BaseExecutionResultHandler.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<List<Tuple>>	BatchCassandraWriterBolt.getAsyncHandler()
protected AsyncResultHandler<Tuple>	CassandraWriterBolt.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	BatchCassandraWriterBolt.process(Tuple input) Process a single non-tick tuple of input.
protected void	CassandraWriterBolt.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

Methods in org.apache.storm.clojure with parameters of type Tuple

Modifier and Type	Method and Description
void	ClojureBolt.execute(Tuple input)

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	IBatchBolt.execute(Tuple tuple)
void	CoordinatedBolt.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.drpc

Methods in org.apache.storm.drpc with parameters of type Tuple

Modifier and Type	Method and Description
void	ReturnResults.execute(Tuple input)
void	KeyedFairBolt.execute(Tuple input)
void	JoinResult.execute(Tuple tuple)
void	PrepareRequest.execute(Tuple tuple, BasicOutputCollector collector)

Uses of Tuple in org.apache.storm.druid.bolt

Methods in org.apache.storm.druid.bolt with parameters of type Tuple

Modifier and Type	Method and Description
protected void	DruidBeamBolt.process(Tuple tuple) Deprecated.

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	EsPercolateBolt.process(Tuple tuple) Process a single non-tick tuple of input.
void	EsLookupBolt.process(Tuple tuple)
void	EsIndexBolt.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)

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
protected void	EventHubBolt.process(Tuple tuple)
byte[]	DefaultEventDataFormat.serialize(Tuple tuple)
byte[]	IEventDataFormat.serialize(Tuple tuple)

Uses of Tuple in org.apache.storm.eventhubs.samples.bolt

Methods in org.apache.storm.eventhubs.samples.bolt with parameters of type Tuple

Modifier and Type	Method and Description
void	PartialCountBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	GlobalCountBolt.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	HBaseLookupBolt.execute(Tuple tuple)
void	HBaseBolt.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	SimpleHBaseMapper.columns(Tuple tuple)
ColumnList	HBaseMapper.columns(Tuple tuple) Given a tuple, return a list of HBase columns to insert.
byte[]	SimpleHBaseMapper.rowKey(Tuple tuple)
byte[]	HBaseMapper.rowKey(Tuple tuple) Given a tuple, return the HBase rowkey.

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	SequenceFileBolt.getWriterKey(Tuple tuple)
protected String	HdfsBolt.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	SequenceFileBolt.makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)
protected AbstractHDFSWriter	HdfsBolt.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[]	RecordFormat.format(Tuple tuple)
byte[]	DelimitedRecordFormat.format(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.key(Tuple tuple)
Object	SequenceFormat.value(Tuple tuple) Given a tuple, return the value that should be written to the sequence file.
org.apache.hadoop.io.Writable	DefaultSequenceFormat.value(Tuple tuple)

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	FileSizeRotationPolicy.mark(Tuple tuple, long offset)
boolean	FileRotationPolicy.mark(Tuple tuple, long offset) Called for every tuple the HdfsBolt executes.

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

Methods in org.apache.storm.hdfs.bolt.sync with parameters of type Tuple

Modifier and Type	Method and Description
boolean	SyncPolicy.mark(Tuple tuple, long offset) Called for every tuple the HdfsBolt executes.
boolean	CountSyncPolicy.mark(Tuple tuple, long offset)

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	SequenceFileWriter.doWrite(Tuple tuple)
protected void	HDFSWriter.doWrite(Tuple tuple)
protected void	AvroGenericRecordHDFSWriter.doWrite(Tuple tuple)
protected abstract void	AbstractHDFSWriter.doWrite(Tuple tuple)
String	Partitioner.getPartitionPath(Tuple tuple) Return a relative path that the tuple should be written to.
String	NullPartitioner.getPartitionPath(Tuple tuple)
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>	JsonRecordHiveMapper.mapPartitions(Tuple tuple)
List<String>	HiveMapper.mapPartitions(Tuple tuple) Given a tuple, return a hive partition values list.
List<String>	DelimitedRecordHiveMapper.mapPartitions(Tuple tuple)
byte[]	JsonRecordHiveMapper.mapRecord(Tuple tuple)
byte[]	HiveMapper.mapRecord(Tuple tuple) Given a tuple, maps to a HiveRecord based on columnFields
byte[]	DelimitedRecordHiveMapper.mapRecord(Tuple tuple)
void	JsonRecordHiveMapper.write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, 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)

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	BoltFailInfo.tuple
Tuple	BoltExecuteInfo.tuple
Tuple	BoltAckInfo.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) Deprecated.

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	TupleToKafkaMapper.getKeyFromTuple(Tuple tuple)
K	FieldNameBasedTupleToKafkaMapper.getKeyFromTuple(Tuple tuple)
V	TupleToKafkaMapper.getMessageFromTuple(Tuple tuple)
V	FieldNameBasedTupleToKafkaMapper.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.metric

Methods in org.apache.storm.metric with parameters of type Tuple

Modifier and Type	Method and Description
void	SystemBolt.execute(Tuple input)
void	MetricsConsumerBolt.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	MongoUpdateBolt.execute(Tuple tuple)
void	MongoInsertBolt.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)

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[]	KafkaHdfsTopo.LineWriter.format(Tuple tuple)
byte[]	StrGenSpoutHdfsBoltTopo.LineWriter.format(Tuple tuple)

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

Methods in org.apache.storm.perf.bolt with parameters of type Tuple

Modifier and Type	Method 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)
Map<String,List<Object>>	JPmmlModelRunner.scoredTuplePerStream(Tuple input)

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	RedisStoreBolt.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	RedisFilterBolt.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.serialization

Methods in org.apache.storm.serialization that return Tuple

Modifier and Type	Method and Description
Tuple	KryoTupleDeserializer.deserialize(byte[] ser)
Tuple	ITupleDeserializer.deserialize(byte[] ser)

Methods in org.apache.storm.serialization with parameters of type Tuple

Modifier and Type	Method and Description
byte[]	KryoTupleSerializer.serialize(Tuple tuple)
byte[]	ITupleSerializer.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.starter

Methods in org.apache.storm.starter with parameters of type Tuple

Modifier and Type	Method and Description
void	TransactionalWords.KeyedCountUpdater.execute(Tuple tuple)
void	TransactionalWords.BucketCountUpdater.execute(Tuple tuple)
void	TransactionalGlobalCount.BatchCount.execute(Tuple tuple)
void	TransactionalGlobalCount.UpdateGlobalCount.execute(Tuple tuple)
void	ResourceAwareExampleTopology.ExclamationBolt.execute(Tuple tuple)
void	ReachTopology.PartialUniquer.execute(Tuple tuple)
void	ReachTopology.CountAggregator.execute(Tuple tuple)
void	MultipleLoggerTopology.ExclamationLoggingBolt.execute(Tuple tuple)
void	ExclamationTopology.ExclamationBolt.execute(Tuple tuple)
void	WordCountTopologyNode.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	WordCountTopology.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	TransactionalWords.Bucketize.execute(Tuple tuple, BasicOutputCollector collector)
void	ThroughputVsLatency.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	ThroughputVsLatency.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	ReachTopology.GetTweeters.execute(Tuple tuple, BasicOutputCollector collector)
void	ReachTopology.GetFollowers.execute(Tuple tuple, BasicOutputCollector collector)
void	ManualDRPC.ExclamationBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	InOrderDeliveryTest.Check.execute(Tuple tuple, BasicOutputCollector collector)
void	FastWordCountTopology.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	FastWordCountTopology.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	BlobStoreAPIWordCountTopology.FilterWords.execute(Tuple tuple, BasicOutputCollector collector)
void	BasicDRPCTopology.ExclaimBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	AnchoredWordCount.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	AnchoredWordCount.WordCount.execute(Tuple tuple, BasicOutputCollector collector)

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

Methods in org.apache.storm.starter.bolt with parameters of type Tuple

Modifier and Type	Method and Description
void	SingleJoinBolt.execute(Tuple tuple)
void	RollingCountBolt.execute(Tuple tuple)
void	RollingCountAggBolt.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.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	TestPlannerBolt.execute(Tuple input)
void	TestGlobalCount.execute(Tuple input)
void	TestEventOrderCheckBolt.execute(Tuple input)
void	TestAggregatesCounter.execute(Tuple input)
void	NonRichBoltTracker.execute(Tuple input)
void	KeyedSummingBatchBolt.execute(Tuple tuple)
void	KeyedCountingBatchBolt.execute(Tuple tuple)
void	CountingCommitBolt.execute(Tuple tuple)
void	CountingBatchBolt.execute(Tuple tuple)
void	BatchNumberList.execute(Tuple tuple)
void	TestWordCounter.execute(Tuple input, BasicOutputCollector collector)
void	TestConfBolt.execute(Tuple input, BasicOutputCollector collector)
void	PrepareBatchBolt.execute(Tuple input, BasicOutputCollector collector)
void	IdentityBolt.execute(Tuple input, BasicOutputCollector collector)
void	BatchRepeatA.execute(Tuple input, BasicOutputCollector collector)
void	BatchProcessWord.execute(Tuple input, BasicOutputCollector collector)
protected String	TestWordCounter.getTupleValue(Tuple t, int idx)
protected String	TestWordBytesCounter.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>	WindowedBoltExecutor.newWindowLifecycleListener()
protected WindowLifecycleListener<Tuple>	StatefulWindowedBoltExecutor.newWindowLifecycleListener()

Methods in org.apache.storm.topology with parameters of type Tuple

Modifier and Type	Method and Description
void	WindowedBoltExecutor.execute(Tuple input)
void	StatefulWindowedBoltExecutor.execute(Tuple input)
void	IStatefulBolt.execute(Tuple input)
void	BasicBoltExecutor.execute(Tuple input)
void	BaseStatefulBoltExecutor.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 void	CheckpointTupleForwarder.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid) Forwards the checkpoint tuple downstream.
protected abstract void	BaseStatefulBoltExecutor.handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid) Sub-classes can implement the logic for handling checkpoint tuple.
protected void	StatefulBoltExecutor.handleTuple(Tuple input)
protected void	CheckpointTupleForwarder.handleTuple(Tuple input) Hands off tuple to the wrapped bolt to execute.
protected abstract void	BaseStatefulBoltExecutor.handleTuple(Tuple input) Sub-classes can implement the logic for handling the tuple.
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)

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.transactional

Methods in org.apache.storm.transactional with parameters of type Tuple

Modifier and Type	Method and Description
void	TransactionalSpoutBatchExecutor.execute(Tuple 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)

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>	TupleWindowImpl.getExpired()
List<Tuple>	TupleWindowImpl.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)

Uses of Tuple in storm.starter

Methods in storm.starter with parameters of type Tuple

Modifier and Type	Method and Description
void	StatefulTopology.PrinterBolt.execute(Tuple tuple, BasicOutputCollector collector)