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

Packages that use TridentTuple

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.hbase.trident
org.apache.storm.hbase.trident.mapper
org.apache.storm.hbase.trident.state
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.mongodb.trident
org.apache.storm.mongodb.trident.state
org.apache.storm.mqtt.trident
org.apache.storm.opentsdb.trident
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.rocketmq.trident.state
org.apache.storm.solr.trident
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.cassandra.trident.state

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

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

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

Modifier and Type	Method and Description
List<List<Values>>	CassandraQuery.batchRetrieve(CassandraState state, List<TridentTuple> tridentTuples)
List<List<Values>>	CassandraState.batchRetrieve(List<TridentTuple> tridentTuples)
void	CassandraStateUpdater.updateState(CassandraState state, List<TridentTuple> list, TridentCollector collector)
void	CassandraState.updateState(List<TridentTuple> tuples, TridentCollector collector)

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 and 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.hbase.trident

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

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

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

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

Modifier and Type	Method and Description
ColumnList	TridentHBaseMapper.columns(TridentTuple tuple) Given a tuple, return a list of HBase columns to insert.
ColumnList	SimpleTridentHBaseMapper.columns(TridentTuple tuple)
byte[]	TridentHBaseMapper.rowKey(TridentTuple tuple) Given a tuple, return the HBase rowkey.
byte[]	SimpleTridentHBaseMapper.rowKey(TridentTuple tuple)

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

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

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

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

Modifier and Type	Method and Description
List<List<Values>>	HBaseQuery.batchRetrieve(HBaseState hBaseState, List<TridentTuple> tridentTuples)
List<List<Values>>	HBaseState.batchRetrieve(List<TridentTuple> tridentTuples)
void	HBaseUpdater.updateState(HBaseState hBaseState, List<TridentTuple> tuples, TridentCollector collector)
void	HBaseState.updateState(List<TridentTuple> tuples, TridentCollector collector)

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 and Description
void	HdfsState.HdfsFileOptions.execute(List<TridentTuple> tuples)
void	HdfsState.SequenceFileOptions.execute(List<TridentTuple> tuples)
void	HdfsUpdater.updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector)
void	HdfsState.updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)

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 and Description
byte[]	RecordFormat.format(TridentTuple tuple)
byte[]	DelimitedRecordFormat.format(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.key(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.
org.apache.hadoop.io.Writable	DefaultSequenceFormat.value(TridentTuple tuple)

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 and Description
boolean	TimedRotationPolicy.mark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.
boolean	NoRotationPolicy.mark(TridentTuple tuple, long offset)
boolean	FileSizeRotationPolicy.mark(TridentTuple tuple, long offset)
boolean	FileRotationPolicy.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 and Description
boolean	SyncPolicy.mark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.
boolean	CountSyncPolicy.mark(TridentTuple tuple, long offset)

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 and Description
List<String>	JsonRecordHiveMapper.mapPartitions(TridentTuple tuple)
List<String>	HiveMapper.mapPartitions(TridentTuple tuple) Given a TridetnTuple, return a hive partition values list.
List<String>	DelimitedRecordHiveMapper.mapPartitions(TridentTuple tuple)
byte[]	JsonRecordHiveMapper.mapRecord(TridentTuple tuple)
byte[]	HiveMapper.mapRecord(TridentTuple tuple) Given a TridentTuple, maps to a HiveRecord based on columnFields
byte[]	DelimitedRecordHiveMapper.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 and Description
void	HiveUpdater.updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)
void	HiveState.updateState(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 and 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 and Description
List<List<Values>>	JdbcQuery.batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)
List<List<Values>>	JdbcState.batchRetrieve(List<TridentTuple> tridentTuples)
void	JdbcUpdater.updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector)
void	JdbcState.updateState(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 and Description
void	JmsUpdater.updateState(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector)
void	JmsState.updateState(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 and 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 and Description
K	TridentTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple)
K	FieldNameBasedTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple)
V	TridentTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple)
V	FieldNameBasedTupleToKafkaMapper.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 and Description
String	KafkaTopicSelector.getTopic(TridentTuple tuple)
String	DefaultTopicSelector.getTopic(TridentTuple tuple)

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

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

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

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

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

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

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

Modifier and Type	Method and Description
List<List<Values>>	MongoState.batchRetrieve(List<TridentTuple> tridentTuples) Batch retrieve values.
List<List<Values>>	MongoStateQuery.batchRetrieve(MongoState mongoState, List<TridentTuple> tridentTuples)
void	MongoState.updateState(List<TridentTuple> tuples, TridentCollector collector) Update Mongo state.
void	MongoStateUpdater.updateState(MongoState state, List<TridentTuple> tuples, TridentCollector collector)

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

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

Modifier and Type	Method and Description
void	MqttPublishFunction.execute(TridentTuple tuple, TridentCollector collector)

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

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

Modifier and Type	Method and Description
void	OpenTsdbState.update(List<TridentTuple> tridentTuples, TridentCollector collector)
void	OpenTsdbStateUpdater.updateState(OpenTsdbState state, List<TridentTuple> tuples, TridentCollector collector)

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 and 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 and 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 and 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.rocketmq.trident.state

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

Modifier and Type	Method and Description
void	RocketMqState.updateState(List<TridentTuple> tuples, TridentCollector collector) Update the RocketMQ state.
void	RocketMqStateUpdater.updateState(RocketMqState state, List<TridentTuple> tuples, TridentCollector collector)

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

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

Modifier and Type	Method and Description
void	SolrState.updateState(List<TridentTuple> tuples)
void	SolrUpdater.updateState(SolrState solrState, List<TridentTuple> tuples, 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 and Description
void	TridentWordCount.Split.execute(TridentTuple tuple, TridentCollector collector)
void	TridentReach.ExpandList.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 and 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 and 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 and 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)
void	MultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
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.
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.
T	GroupedMultiReducer.init(TridentCollector collector, TridentTuple group)
T	CombinerAggregator.init(TridentTuple tuple)
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 and 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	TupleCollectionGet.execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector)
void	SnapshotGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
void	MapGet.execute(TridentTuple tuple, Object result, TridentCollector collector)
Number	Sum.init(TridentTuple tuple)
Long	Count.init(TridentTuple tuple)
boolean	Negate.isKeep(TridentTuple tuple)
boolean	FilterNull.isKeep(TridentTuple tuple)
boolean	Equals.isKeep(TridentTuple tuple)
boolean	Debug.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 and 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 and 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 and Description
void	ChainedAggregatorImpl.aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector)
void	GroupedAggregator.aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector)
void	ReducerAggregatorImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	CombinerAggregatorCombineImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector)
void	SingleEmitAggregator.aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	JoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector)
void	PreservingFieldsOrderJoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)
void	JoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, 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	MapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FlatMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	FilterExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	ConsumerExecutor.execute(TridentTuple tuple, TridentCollector collector)
void	CombinerAggregatorInitImpl.execute(TridentTuple tuple, TridentCollector collector)
JoinState	PreservingFieldsOrderJoinerMultiReducer.init(TridentCollector collector, TridentTuple group)
JoinState	JoinerMultiReducer.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 and Description
void	GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state, TridentCollector collector)
void	GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
void	ReducerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)
void	CombinerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector)

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

Constructor and 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 and Description
void	TupleReceiver.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	BridgeReceiver.execute(ProcessorContext context, 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 and Description
void	StateQueryProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	ProjectedProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	PartitionPersistProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	MultiReducerProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	MapProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	EachProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	AggregateProcessor.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 and 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 and 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

Constructor and 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 and Description
void	MapReducerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)
void	MapCombinerAggStateUpdater.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 and Description
void	CountAsAggregator.aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)
void	TuplifyArgs.execute(TridentTuple input, TridentCollector collector)
void	StringLength.execute(TridentTuple tuple, TridentCollector collector)
void	Split.execute(TridentTuple tuple, 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 and 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 and Description
TridentTuple	TridentTupleView.FreshOutputFactory.create(List<Object> selfVals)
TridentTuple	TridentTupleView.ProjectionFactory.create(TridentTuple parent)
TridentTuple	TridentTupleView.OperationOutputFactory.create(TridentTupleView parent, List<Object> selfVals)
TridentTuple	TridentTupleView.RootFactory.create(Tuple parent)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, List<Object> values)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, Object... values)

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

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

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

Modifier and Type	Method and 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 and Description
void	StoreBasedTridentWindowManager.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	InMemoryTridentWindowManager.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

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