Uses of Interface
org.apache.storm.trident.tuple.TridentTuple
Packages that use TridentTuple
Package
Description
-
Uses of TridentTuple in org.apache.storm.hdfs.trident
Method parameters in org.apache.storm.hdfs.trident with type arguments of type TridentTupleModifier and TypeMethodDescriptionvoidHdfsState.HdfsFileOptions.execute(List<TridentTuple> tuples) voidHdfsState.SequenceFileOptions.execute(List<TridentTuple> tuples) voidHdfsState.updateState(List<TridentTuple> tuples, TridentCollector tridentCollector) voidHdfsUpdater.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 TridentTupleModifier and TypeMethodDescriptionbyte[]DelimitedRecordFormat.format(TridentTuple tuple) byte[]RecordFormat.format(TridentTuple tuple) org.apache.hadoop.io.WritableDefaultSequenceFormat.key(TridentTuple tuple) org.apache.hadoop.io.WritableSequenceFormat.key(TridentTuple tuple) Given a tuple, return the key that should be written to the sequence file.org.apache.hadoop.io.WritableDefaultSequenceFormat.value(TridentTuple tuple) org.apache.hadoop.io.WritableSequenceFormat.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 TridentTupleModifier and TypeMethodDescriptionbooleanFileRotationPolicy.mark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.booleanFileSizeRotationPolicy.mark(TridentTuple tuple, long offset) booleanNoRotationPolicy.mark(TridentTuple tuple, long offset) booleanTimedRotationPolicy.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 TridentTupleModifier and TypeMethodDescriptionbooleanCountSyncPolicy.mark(TridentTuple tuple, long offset) booleanSyncPolicy.mark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes. -
Uses of TridentTuple in org.apache.storm.jdbc.trident.state
Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidJdbcQuery.execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector) Method parameters in org.apache.storm.jdbc.trident.state with type arguments of type TridentTupleModifier and TypeMethodDescriptionJdbcQuery.batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples) JdbcState.batchRetrieve(List<TridentTuple> tridentTuples) voidJdbcState.updateState(List<TridentTuple> tuples, TridentCollector collector) voidJdbcUpdater.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 TridentTupleModifier and TypeMethodDescriptionvoidJmsState.updateState(List<TridentTuple> tuples, TridentCollector collector) voidJmsUpdater.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 TridentTupleModifier and TypeMethodDescriptionvoidTridentKafkaState.updateState(List<TridentTuple> tuples, TridentCollector collector) Write the given tuples to Kafka.voidTridentKafkaStateUpdater.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 TridentTupleModifier and TypeMethodDescriptionFieldNameBasedTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple) TridentTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple) FieldNameBasedTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple) 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 TridentTupleModifier and TypeMethodDescriptionDefaultTopicSelector.getTopic(TridentTuple tuple) KafkaTopicSelector.getTopic(TridentTuple tuple) -
Uses of TridentTuple in org.apache.storm.redis.trident
Methods in org.apache.storm.redis.trident with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidPrintFunction.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 TridentTupleModifier and TypeMethodDescriptionvoidAbstractRedisStateQuerier.execute(TridentTuple tuple, List<Values> values, TridentCollector collector) Method parameters in org.apache.storm.redis.trident.state with type arguments of type TridentTupleModifier and TypeMethodDescriptionAbstractRedisStateQuerier.batchRetrieve(T state, List<TridentTuple> inputs) voidAbstractRedisStateUpdater.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 TridentTupleModifier and TypeMethodDescriptionvoidTridentReach.ExpandList.execute(TridentTuple tuple, TridentCollector collector) voidTridentWordCount.Split.execute(TridentTuple tuple, TridentCollector collector) 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 TridentTupleModifier and TypeMethodDescriptionStream.max(Comparator<TridentTuple> comparator) This aggregator operation computes the maximum of tuples in a stream by using the givencomparatorwithTridentTuples.Stream.min(Comparator<TridentTuple> comparator) This aggregator operation computes the minimum of tuples in a stream by using the givencomparatorwithTridentTuples. -
Uses of TridentTuple in org.apache.storm.trident.drpc
Methods in org.apache.storm.trident.drpc with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidReturnResultsReducer.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 TridentTupleModifier and TypeMethodDescriptionvoidConsumer.accept(TridentTuple input) Performs the operation on the input trident tuple.voidAggregator.aggregate(T val, TridentTuple tuple, TridentCollector collector) voidGroupedMultiReducer.complete(T state, TridentTuple group, TridentCollector collector) FlatMapFunction.execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.voidFunction.execute(TridentTuple tuple, TridentCollector collector) Performs the function logic on an individual tuple and emits 0 or more tuples.voidGroupedMultiReducer.execute(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) MapFunction.execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.voidMultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector) CombinerAggregator.init(TridentTuple tuple) GroupedMultiReducer.init(TridentCollector collector, TridentTuple group) booleanFilter.isKeep(TridentTuple tuple) Determines if a tuple should be filtered out of a stream.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 TridentTupleModifier and TypeMethodDescriptionvoidComparisonAggregator.aggregate(ComparisonAggregator.State state, TridentTuple tuple, TridentCollector collector) voidFirstN.FirstNAgg.aggregate(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentTuple tuple, TridentCollector collector) voidFirstN.FirstNSortedAgg.aggregate(PriorityQueue state, TridentTuple tuple, TridentCollector collector) voidMapGet.execute(TridentTuple tuple, Object result, TridentCollector collector) voidSnapshotGet.execute(TridentTuple tuple, Object result, TridentCollector collector) voidTupleCollectionGet.execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector) Count.init(TridentTuple tuple) Sum.init(TridentTuple tuple) booleanDebug.isKeep(TridentTuple tuple) booleanEquals.isKeep(TridentTuple tuple) booleanFilterNull.isKeep(TridentTuple tuple) booleanNegate.isKeep(TridentTuple tuple) protected TComparisonAggregator.valueFromTuple(TridentTuple tuple) Method parameters in org.apache.storm.trident.operation.builtin with type arguments of type TridentTupleModifier and TypeMethodDescriptionMapGet.batchRetrieve(ReadOnlyMapState map, List<TridentTuple> keys) SnapshotGet.batchRetrieve(ReadOnlySnapshottable state, List<TridentTuple> args) 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 TridentTupleMethods in org.apache.storm.trident.operation.impl with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidChainedAggregatorImpl.aggregate(ChainedResult val, TridentTuple tuple, TridentCollector collector) voidCombinerAggregatorCombineImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector) voidGroupedAggregator.aggregate(Object[] arr, TridentTuple tuple, TridentCollector collector) voidReducerAggregatorImpl.aggregate(Result val, TridentTuple tuple, TridentCollector collector) voidSingleEmitAggregator.aggregate(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, TridentTuple tuple, TridentCollector collector) voidJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector) voidPreservingFieldsOrderJoinerMultiReducer.complete(JoinState state, TridentTuple group, TridentCollector collector) voidCombinerAggregatorInitImpl.execute(TridentTuple tuple, TridentCollector collector) voidConsumerExecutor.execute(TridentTuple tuple, TridentCollector collector) voidFilterExecutor.execute(TridentTuple tuple, TridentCollector collector) voidFlatMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector) voidGroupedMultiReducerExecutor.execute(Map<TridentTuple, Object> state, int streamIndex, TridentTuple full, TridentCollector collector) voidIdentityMultiReducer.execute(T state, int streamIndex, TridentTuple input, TridentCollector collector) voidJoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) voidMapFunctionExecutor.execute(TridentTuple tuple, TridentCollector collector) voidPreservingFieldsOrderJoinerMultiReducer.execute(JoinState state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) JoinerMultiReducer.init(TridentCollector collector, TridentTuple group) PreservingFieldsOrderJoinerMultiReducer.init(TridentCollector collector, TridentTuple group) booleanTrueFilter.isKeep(TridentTuple tuple) Method parameters in org.apache.storm.trident.operation.impl with type arguments of type TridentTupleModifier and TypeMethodDescriptionvoidGroupedMultiReducerExecutor.complete(Map<TridentTuple, Object> state, TridentCollector collector) voidGroupedMultiReducerExecutor.execute(Map<TridentTuple, Object> state, int streamIndex, TridentTuple full, TridentCollector collector) voidCombinerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector) voidReducerAggStateUpdater.updateState(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector) Constructors in org.apache.storm.trident.operation.impl with parameters of type TridentTuple -
Uses of TridentTuple in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidBridgeReceiver.execute(ProcessorContext context, String streamId, TridentTuple tuple) voidTupleReceiver.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 TridentTupleModifier and TypeMethodDescriptionvoidAggregateProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidEachProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidMapProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidMultiReducerProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidPartitionPersistProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidProjectedProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidStateQueryProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidAppendCollector.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 TridentTupleModifier and TypeMethodDescriptionvoidQueryFunction.execute(TridentTuple tuple, T result, TridentCollector collector) Method parameters in org.apache.storm.trident.state with type arguments of type TridentTupleModifier and TypeMethodDescriptionQueryFunction.batchRetrieve(S state, List<TridentTuple> args) voidStateUpdater.updateState(S state, List<TridentTuple> tuples, TridentCollector collector) Constructor parameters in org.apache.storm.trident.state with type arguments of type TridentTupleModifierConstructorDescriptionReducerValueUpdater(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 TridentTupleModifier and TypeMethodDescriptionvoidMapCombinerAggStateUpdater.updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector) voidMapReducerAggStateUpdater.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 TridentTupleModifier and TypeMethodDescriptionvoidCountAsAggregator.aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector) voidSplit.execute(TridentTuple tuple, TridentCollector collector) voidStringLength.execute(TridentTuple tuple, TridentCollector collector) voidTuplifyArgs.execute(TridentTuple input, TridentCollector collector) booleanTrueFilter.isKeep(TridentTuple tuple) -
Uses of TridentTuple in org.apache.storm.trident.tuple
Classes in org.apache.storm.trident.tuple that implement TridentTupleModifier and TypeClassDescriptionclassExtends AbstractList so that it can be emitted directly as Storm tuples.Methods in org.apache.storm.trident.tuple that return TridentTupleModifier and TypeMethodDescriptionTridentTupleView.OperationOutputFactory.create(TridentTupleView parent, List<Object> selfVals) TridentTupleView.ProjectionFactory.create(TridentTuple parent) static TridentTupleTridentTupleView.createFreshTuple(Fields fields, Object... values) static TridentTupleTridentTupleView.createFreshTuple(Fields fields, List<Object> values) Methods in org.apache.storm.trident.tuple with parameters of type TridentTuple -
Uses of TridentTuple in org.apache.storm.trident.windowing
Methods in org.apache.storm.trident.windowing that return TridentTupleModifier and TypeMethodDescriptionStoreBasedTridentWindowManager.collectTridentTupleOrKey(TridentBatchTuple tridentBatchTuple, List<String> keys) Methods in org.apache.storm.trident.windowing that return types with arguments of type TridentTupleModifier and TypeMethodDescriptionprotected abstract List<TridentTuple>AbstractTridentWindowManager.getTridentTuples(List<T> tupleEvents) ReturnTridentTuples from giventupleEvents.InMemoryTridentWindowManager.getTridentTuples(List<TridentTuple> tridentBatchTuples) StoreBasedTridentWindowManager.getTridentTuples(List<TridentBatchTuple> tridentBatchTuples) Methods in org.apache.storm.trident.windowing with parameters of type TridentTupleModifier and TypeMethodDescriptionvoidWindowTridentProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple) Method parameters in org.apache.storm.trident.windowing with type arguments of type TridentTupleModifier and TypeMethodDescriptionvoidInMemoryTridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples) voidITridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples) Add received batch of tuples to cache/store and add them toWindowManager.voidStoreBasedTridentWindowManager.addTuplesBatch(Object batchId, List<TridentTuple> tuples) InMemoryTridentWindowManager.getTridentTuples(List<TridentTuple> tridentBatchTuples) voidInMemoryTridentWindowManager.onTuplesExpired(List<TridentTuple> expiredTuples) voidWindowsStateUpdater.updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector) Constructors in org.apache.storm.trident.windowing with parameters of type TridentTupleModifierConstructorDescriptionTridentBatchTuple(String effectiveBatchId, long timeStamp, int tupleIndex, TridentTuple tridentTuple)