Uses of Interface
backtype.storm.tuple.Tuple

Packages that use Tuple

Package	Description
backtype.storm.clojure
backtype.storm.coordination
backtype.storm.drpc
backtype.storm.hooks.info
backtype.storm.metric
backtype.storm.serialization
backtype.storm.state
backtype.storm.task
backtype.storm.testing
backtype.storm.topology
backtype.storm.transactional
backtype.storm.tuple
backtype.storm.utils
storm.trident.planner
storm.trident.spout
storm.trident.topology
storm.trident.tuple

Uses of Tuple in backtype.storm.clojure

Methods in backtype.storm.clojure with parameters of type Tuple

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

Uses of Tuple in backtype.storm.coordination

Methods in backtype.storm.coordination with parameters of type Tuple

Modifier and Type	Method and Description
void	BatchOutputCollectorImpl.ack(Tuple tup)
void	CoordinatedBolt.CoordinatedOutputCollector.ack(Tuple tuple)
void	BatchBoltExecutor.execute(Tuple input)
void	IBatchBolt.execute(Tuple tuple)
void	CoordinatedBolt.execute(Tuple tuple)
void	BatchOutputCollectorImpl.fail(Tuple tup)
void	CoordinatedBolt.CoordinatedOutputCollector.fail(Tuple tuple)

Method parameters in backtype.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 backtype.storm.drpc

Methods in backtype.storm.drpc with parameters of type Tuple

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

Uses of Tuple in backtype.storm.hooks.info

Fields in backtype.storm.hooks.info declared as Tuple

Modifier and Type	Field and Description
Tuple	BoltExecuteInfo.tuple
Tuple	BoltAckInfo.tuple
Tuple	BoltFailInfo.tuple

Constructors in backtype.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 backtype.storm.metric

Methods in backtype.storm.metric with parameters of type Tuple

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

Uses of Tuple in backtype.storm.serialization

Methods in backtype.storm.serialization that return Tuple

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

Methods in backtype.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 backtype.storm.state

Methods in backtype.storm.state with parameters of type Tuple

Modifier and Type	Method and Description
void	ISubscribedState.set(Object id, Tuple tuple)

Uses of Tuple in backtype.storm.task

Methods in backtype.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	IBolt.execute(Tuple input) Process a single tuple of input.
void	ShellBolt.execute(Tuple input)
void	OutputCollector.fail(Tuple input)
void	IOutputCollector.fail(Tuple input)

Method parameters in backtype.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 backtype.storm.testing

Methods in backtype.storm.testing with parameters of type Tuple

Modifier and Type	Method and Description
void	KeyedCountingBatchBolt.execute(Tuple tuple)
void	NonRichBoltTracker.execute(Tuple input)
void	CountingBatchBolt.execute(Tuple tuple)
void	TestGlobalCount.execute(Tuple input)
void	TupleCaptureBolt.execute(Tuple input)
void	KeyedSummingBatchBolt.execute(Tuple tuple)
void	TestEventOrderCheckBolt.execute(Tuple input)
void	CountingCommitBolt.execute(Tuple tuple)
void	TestAggregatesCounter.execute(Tuple input)
void	TestPlannerBolt.execute(Tuple input)
void	BatchNumberList.execute(Tuple tuple)
void	BatchRepeatA.execute(Tuple input, BasicOutputCollector collector)
void	TestConfBolt.execute(Tuple input, BasicOutputCollector collector)
void	BatchProcessWord.execute(Tuple input, BasicOutputCollector collector)
void	IdentityBolt.execute(Tuple input, BasicOutputCollector collector)
void	TestWordCounter.execute(Tuple input, BasicOutputCollector collector)
void	PrepareBatchBolt.execute(Tuple input, BasicOutputCollector collector)

Uses of Tuple in backtype.storm.topology

Methods in backtype.storm.topology with parameters of type Tuple

Modifier and Type	Method and Description
void	BasicBoltExecutor.execute(Tuple input)
void	IBasicBolt.execute(Tuple input, BasicOutputCollector collector) Process the input tuple and optionally emit new tuples based on the input tuple.
void	BasicOutputCollector.setContext(Tuple inputTuple)

Uses of Tuple in backtype.storm.transactional

Methods in backtype.storm.transactional with parameters of type Tuple

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

Uses of Tuple in backtype.storm.tuple

Classes in backtype.storm.tuple that implement Tuple

Modifier and Type	Class and Description
class	TupleImpl

Uses of Tuple in backtype.storm.utils

Methods in backtype.storm.utils with parameters of type Tuple

Modifier and Type	Method and Description
static boolean	TupleUtils.isTick(Tuple tuple)

Uses of Tuple in storm.trident.planner

Methods in 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 storm.trident.spout

Methods in 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 storm.trident.topology

Methods in storm.trident.topology with parameters of type Tuple

Modifier and Type	Method and Description
void	TridentBoltExecutor.CoordinatedOutputCollector.ack(Tuple tuple)
void	ITridentBatchBolt.execute(BatchInfo batchInfo, Tuple tuple)
void	TridentBoltExecutor.execute(Tuple tuple)
void	TridentBoltExecutor.CoordinatedOutputCollector.fail(Tuple tuple)

Method parameters in storm.trident.topology with type arguments of type Tuple

Modifier and Type	Method and Description
List<Integer>	TridentBoltExecutor.CoordinatedOutputCollector.emit(String stream, Collection<Tuple> anchors, List<Object> tuple)
void	TridentBoltExecutor.CoordinatedOutputCollector.emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)

Uses of Tuple in storm.trident.tuple

Methods in storm.trident.tuple with parameters of type Tuple

Modifier and Type	Method and Description
TridentTuple	TridentTupleView.RootFactory.create(Tuple parent)