Uses of Interface
org.apache.storm.trident.tuple.TridentTuple

Packages that use TridentTuple

Package	Description
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.hdfs.trident
org.apache.storm.hdfs.trident.format
org.apache.storm.hdfs.trident.rotation
org.apache.storm.hdfs.trident.sync
org.apache.storm.hive.bolt.mapper
org.apache.storm.hive.trident
org.apache.storm.jdbc.trident.state
org.apache.storm.jms.trident
org.apache.storm.kafka.trident
org.apache.storm.kafka.trident.mapper
org.apache.storm.kafka.trident.selector
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.starter.trident
org.apache.storm.trident
org.apache.storm.trident.drpc
org.apache.storm.trident.operation
org.apache.storm.trident.operation.builtin
org.apache.storm.trident.operation.impl
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.state
org.apache.storm.trident.state.map
org.apache.storm.trident.testing
org.apache.storm.trident.tuple
org.apache.storm.trident.windowing

Uses of TridentTuple in org.apache.storm.elasticsearch.trident

Method parameters in org.apache.storm.elasticsearch.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	EsUpdater.updateState(org.apache.storm.elasticsearch.trident.EsState state, List<TridentTuple> tuples, TridentCollector collector)	Each tuple should have relevant fields (source, index, type, id) for EsState's tupleMapper to extract ES document.

Uses of TridentTuple in org.apache.storm.hdfs.trident

Method parameters in org.apache.storm.hdfs.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	HdfsState.HdfsFileOptions.execute(List<TridentTuple> tuples)
void	HdfsState.SequenceFileOptions.execute(List<TridentTuple> tuples)
void	HdfsState.updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)
void	HdfsUpdater.updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.hdfs.trident.format

Methods in org.apache.storm.hdfs.trident.format with parameters of type TridentTuple

Modifier and Type	Method	Description
byte[]	DelimitedRecordFormat.format(TridentTuple tuple)
byte[]	RecordFormat.format(TridentTuple tuple)
org.apache.hadoop.io.Writable	DefaultSequenceFormat.key(TridentTuple tuple)
org.apache.hadoop.io.Writable	SequenceFormat.key(TridentTuple tuple)	Given a tuple, return the key that should be written to the sequence file.
org.apache.hadoop.io.Writable	DefaultSequenceFormat.value(TridentTuple tuple)
org.apache.hadoop.io.Writable	SequenceFormat.value(TridentTuple tuple)	Given a tuple, return the value that should be written to the sequence file.

Uses of TridentTuple in org.apache.storm.hdfs.trident.rotation

Methods in org.apache.storm.hdfs.trident.rotation with parameters of type TridentTuple

Modifier and Type	Method	Description
boolean	FileRotationPolicy.mark(TridentTuple tuple, long offset)	Called for every tuple the HdfsBolt executes.
boolean	FileSizeRotationPolicy.mark(TridentTuple tuple, long offset)
boolean	NoRotationPolicy.mark(TridentTuple tuple, long offset)
boolean	TimedRotationPolicy.mark(TridentTuple tuple, long offset)	Called for every tuple the HdfsBolt executes.

Uses of TridentTuple in org.apache.storm.hdfs.trident.sync

Methods in org.apache.storm.hdfs.trident.sync with parameters of type TridentTuple

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

Uses of TridentTuple in org.apache.storm.hive.bolt.mapper

Methods in org.apache.storm.hive.bolt.mapper with parameters of type TridentTuple

Modifier and Type	Method	Description
List<String>	DelimitedRecordHiveMapper.mapPartitions(TridentTuple tuple)
List<String>	HiveMapper.mapPartitions(TridentTuple tuple)	Given a TridetnTuple, return a hive partition values list.
List<String>	JsonRecordHiveMapper.mapPartitions(TridentTuple tuple)
byte[]	DelimitedRecordHiveMapper.mapRecord(TridentTuple tuple)
byte[]	HiveMapper.mapRecord(TridentTuple tuple)	Given a TridentTuple, maps to a HiveRecord based on columnFields.
byte[]	JsonRecordHiveMapper.mapRecord(TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.hive.trident

Method parameters in org.apache.storm.hive.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	HiveState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	HiveUpdater.updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.jdbc.trident.state

Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentTuple

Modifier and Type	Method	Description
void	JdbcQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)

Method parameters in org.apache.storm.jdbc.trident.state with type arguments of type TridentTuple

Modifier and Type	Method	Description
List<List<Values>>	JdbcQuery.batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)
List<List<Values>>	JdbcState.batchRetrieve(List<TridentTuple> tridentTuples)
void	JdbcState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	JdbcUpdater.updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.jms.trident

Method parameters in org.apache.storm.jms.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	JmsState.updateState(List<TridentTuple> tuples, TridentCollector collector)
void	JmsUpdater.updateState(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.kafka.trident

Method parameters in org.apache.storm.kafka.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	TridentKafkaState.updateState(List<TridentTuple> tuples, TridentCollector collector)	Write the given tuples to Kafka.
void	TridentKafkaStateUpdater.updateState(TridentKafkaState<K,V> state, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.kafka.trident.mapper

Methods in org.apache.storm.kafka.trident.mapper with parameters of type TridentTuple

Modifier and Type	Method	Description
K	FieldNameBasedTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple)
K	TridentTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple)
V	FieldNameBasedTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple)
V	TridentTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.kafka.trident.selector

Methods in org.apache.storm.kafka.trident.selector with parameters of type TridentTuple

Modifier and Type	Method	Description
String	DefaultTopicSelector.getTopic(TridentTuple tuple)
String	KafkaTopicSelector.getTopic(TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.redis.trident

Methods in org.apache.storm.redis.trident with parameters of type TridentTuple

Modifier and Type	Method	Description
void	PrintFunction.execute(TridentTuple tuple, TridentCollector tridentCollector)

Uses of TridentTuple in org.apache.storm.redis.trident.state

Methods in org.apache.storm.redis.trident.state with parameters of type TridentTuple

Modifier and Type	Method	Description
void	AbstractRedisStateQuerier.execute(TridentTuple tuple, List<Values> values, TridentCollector collector)

Method parameters in org.apache.storm.redis.trident.state with type arguments of type TridentTuple

Modifier and Type	Method	Description
List<List<Values>>	AbstractRedisStateQuerier.batchRetrieve(T state, List<TridentTuple> inputs)
void	AbstractRedisStateUpdater.updateState(T state, List<TridentTuple> inputs, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.starter.trident

Methods in org.apache.storm.starter.trident with parameters of type TridentTuple

Modifier and Type	Method	Description
void	TridentReach.ExpandList.execute(TridentTuple tuple, TridentCollector collector)
void	TridentWordCount.Split.execute(TridentTuple tuple, TridentCollector collector)
Integer	TridentReach.One.init(TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.trident

Method parameters in org.apache.storm.trident with type arguments of type TridentTuple

Modifier and Type	Method	Description
Stream	Stream.max(Comparator<TridentTuple> comparator)	This aggregator operation computes the maximum of tuples in a stream by using the given comparator with TridentTuples.
Stream	Stream.min(Comparator<TridentTuple> comparator)	This aggregator operation computes the minimum of tuples in a stream by using the given comparator with TridentTuples.

Uses of TridentTuple in org.apache.storm.trident.drpc

Methods in org.apache.storm.trident.drpc with parameters of type TridentTuple

Modifier and Type	Method	Description
void	ReturnResultsReducer.execute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.trident.operation

Methods in org.apache.storm.trident.operation with parameters of type TridentTuple

Modifier and Type	Method	Description
void	Consumer.accept(TridentTuple input)	Performs the operation on the input trident tuple.
void	Aggregator.aggregate(T val, TridentTuple tuple, TridentCollector collector)
void	GroupedMultiReducer.complete(T state, TridentTuple group, TridentCollector collector)
Iterable<Values>	FlatMapFunction.execute(TridentTuple input)	Invoked by the framework for each trident tuple in a stream.
void	Function.execute(TridentTuple tuple, TridentCollector collector)	Performs the function logic on an individual tuple and emits 0 or more tuples.
void	GroupedMultiReducer.execute(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
Values	MapFunction.execute(TridentTuple input)	Invoked by the framework for each trident tuple in a stream.
void	MultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
T	CombinerAggregator.init(TridentTuple tuple)
T	GroupedMultiReducer.init(TridentCollector collector, TridentTuple group)
boolean	Filter.isKeep(TridentTuple tuple)	Determines if a tuple should be filtered out of a stream.
T	ReducerAggregator.reduce(T curr, TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.trident.operation.builtin

Methods in org.apache.storm.trident.operation.builtin with parameters of type TridentTuple

Modifier and Type	Method	Description
void	ComparisonAggregator.aggregate(ComparisonAggregator.State state, TridentTuple tuple, TridentCollector collector)
void	FirstN.FirstNAgg.aggregate(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentTuple tuple, TridentCollector collector)
void	FirstN.FirstNSortedAgg.aggregate(PriorityQueue state, TridentTuple tuple, TridentCollector collector)
void	MapGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	SnapshotGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	TupleCollectionGet.execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector)
Long	Count.init(TridentTuple tuple)
Number	Sum.init(TridentTuple tuple)
boolean	Debug.isKeep(TridentTuple tuple)
boolean	Equals.isKeep(TridentTuple tuple)
boolean	FilterNull.isKeep(TridentTuple tuple)
boolean	Negate.isKeep(TridentTuple tuple)
protected T	ComparisonAggregator.valueFromTuple(TridentTuple tuple)

Method parameters in org.apache.storm.trident.operation.builtin with type arguments of type TridentTuple

Modifier and Type	Method	Description
List<Object>	MapGet.batchRetrieve(ReadOnlyMapState map, List<TridentTuple> keys)
List<Object>	SnapshotGet.batchRetrieve(ReadOnlySnapshottable state, List<TridentTuple> args)
List<Iterator<List<Object>>>	TupleCollectionGet.batchRetrieve(State state, List<TridentTuple> args)

Uses of TridentTuple in org.apache.storm.trident.operation.impl

Methods in org.apache.storm.trident.operation.impl that return types with arguments of type TridentTuple

Modifier and Type	Method	Description
Map<TridentTuple,Object>	GroupedMultiReducerExecutor.init(TridentCollector collector)

Methods in org.apache.storm.trident.operation.impl with parameters of type TridentTuple

Modifier and Type	Method	Description
void	ChainedAggregatorImpl.aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector)
void	CombinerAggregatorCombineImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	GroupedAggregator.aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector)
void	ReducerAggregatorImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	SingleEmitAggregator.aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)
void	JoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	CombinerAggregatorInitImpl.execute(TridentTuple tuple, TridentCollector collector)
void	ConsumerExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FilterExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FlatMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
void	IdentityMultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
void	JoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
void	MapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
JoinState	JoinerMultiReducer.init(TridentCollector collector, TridentTuple group)
JoinState	PreservingFieldsOrderJoinerMultiReducer.init(TridentCollector collector, TridentTuple group)
boolean	TrueFilter.isKeep(TridentTuple tuple)

Method parameters in org.apache.storm.trident.operation.impl with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state, TridentCollector collector)
void	GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
void	CombinerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)
void	ReducerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)

Constructors in org.apache.storm.trident.operation.impl with parameters of type TridentTuple

Modifier	Constructor	Description
	JoinState(int numSides, TridentTuple group)

Uses of TridentTuple in org.apache.storm.trident.planner

Methods in org.apache.storm.trident.planner with parameters of type TridentTuple

Modifier and Type	Method	Description
void	BridgeReceiver.execute(ProcessorContext context, String streamId, TridentTuple tuple)
void	TupleReceiver.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.trident.planner.processor

Methods in org.apache.storm.trident.planner.processor with parameters of type TridentTuple

Modifier and Type	Method	Description
void	AggregateProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	EachProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	MapProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	MultiReducerProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	PartitionPersistProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	ProjectedProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	StateQueryProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	AppendCollector.setContext(ProcessorContext pc, TridentTuple t)

Uses of TridentTuple in org.apache.storm.trident.state

Methods in org.apache.storm.trident.state with parameters of type TridentTuple

Modifier and Type	Method	Description
void	QueryFunction.execute(TridentTuple tuple, T result, TridentCollector collector)

Method parameters in org.apache.storm.trident.state with type arguments of type TridentTuple

Modifier and Type	Method	Description
List<T>	QueryFunction.batchRetrieve(S state, List<TridentTuple> args)
void	StateUpdater.updateState(S state, List<TridentTuple> tuples, TridentCollector collector)

Constructor parameters in org.apache.storm.trident.state with type arguments of type TridentTuple

Modifier	Constructor	Description
	ReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples)

Uses of TridentTuple in org.apache.storm.trident.state.map

Method parameters in org.apache.storm.trident.state.map with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	MapCombinerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)
void	MapReducerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)

Uses of TridentTuple in org.apache.storm.trident.testing

Methods in org.apache.storm.trident.testing with parameters of type TridentTuple

Modifier and Type	Method	Description
void	CountAsAggregator.aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)
void	Split.execute(TridentTuple tuple, TridentCollector collector)
void	StringLength.execute(TridentTuple tuple, TridentCollector collector)
void	TuplifyArgs.execute(TridentTuple input, TridentCollector collector)
boolean	TrueFilter.isKeep(TridentTuple tuple)

Uses of TridentTuple in org.apache.storm.trident.tuple

Classes in org.apache.storm.trident.tuple that implement TridentTuple

Modifier and Type	Class	Description
class	TridentTupleView	Extends AbstractList so that it can be emitted directly as Storm tuples.

Methods in org.apache.storm.trident.tuple that return TridentTuple

Modifier and Type	Method	Description
TridentTuple	TridentTupleView.FreshOutputFactory.create(List<Object> selfVals)
TridentTuple	TridentTupleView.OperationOutputFactory.create(TridentTupleView parent, List<Object> selfVals)
TridentTuple	TridentTupleView.ProjectionFactory.create(TridentTuple parent)
TridentTuple	TridentTupleView.RootFactory.create(Tuple parent)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, Object... values)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, List<Object> values)

Methods in org.apache.storm.trident.tuple with parameters of type TridentTuple

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

Uses of TridentTuple in org.apache.storm.trident.windowing

Methods in org.apache.storm.trident.windowing that return TridentTuple

Modifier and Type	Method	Description
TridentTuple	StoreBasedTridentWindowManager.collectTridentTupleOrKey(TridentBatchTuple tridentBatchTuple, List<String> keys)

Methods in org.apache.storm.trident.windowing that return types with arguments of type TridentTuple

Modifier and Type	Method	Description
protected abstract List<TridentTuple>	AbstractTridentWindowManager.getTridentTuples(List<T> tupleEvents)	Return TridentTuples from given tupleEvents.
List<TridentTuple>	InMemoryTridentWindowManager.getTridentTuples(List<TridentTuple> tridentBatchTuples)
List<TridentTuple>	StoreBasedTridentWindowManager.getTridentTuples(List<TridentBatchTuple> tridentBatchTuples)

Methods in org.apache.storm.trident.windowing with parameters of type TridentTuple

Modifier and Type	Method	Description
void	WindowTridentProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)

Method parameters in org.apache.storm.trident.windowing with type arguments of type TridentTuple

Modifier and Type	Method	Description
void	InMemoryTridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples)
void	ITridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples)	Add received batch of tuples to cache/store and add them to WindowManager.
void	StoreBasedTridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples)
List<TridentTuple>	InMemoryTridentWindowManager.getTridentTuples(List<TridentTuple> tridentBatchTuples)
void	InMemoryTridentWindowManager.onTuplesExpired(List<TridentTuple> expiredTuples)
void	WindowsStateUpdater.updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)

Constructors in org.apache.storm.trident.windowing with parameters of type TridentTuple

Modifier	Constructor	Description
	TridentBatchTuple(String effectiveBatchId, long timeStamp, int tupleIndex, TridentTuple tridentTuple)