Uses of Interface
org.apache.storm.trident.operation.TridentCollector
Package
Description
ElasticSearch Trident example classes.
-
Uses of TridentCollector in org.apache.storm.elasticsearch.trident
Modifier and TypeMethodDescriptionvoid
TridentEsTopology.FixedBatchSpout.emitBatch
(long batchId, TridentCollector collector) Emits a batch.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 TridentCollector in org.apache.storm.hdfs.trident
Modifier and TypeMethodDescriptionvoid
FixedBatchSpout.emitBatch
(long batchId, TridentCollector collector) void
HdfsState.updateState
(List<TridentTuple> tuples, TridentCollector tridentCollector) void
HdfsUpdater.updateState
(HdfsState state, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.hive.trident
Modifier and TypeMethodDescriptionvoid
TridentHiveTopology.FixedBatchSpout.emitBatch
(long batchId, TridentCollector collector) void
HiveState.updateState
(List<TridentTuple> tuples, TridentCollector collector) void
HiveUpdater.updateState
(HiveState state, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.jdbc.trident.state
Modifier and TypeMethodDescriptionvoid
JdbcQuery.execute
(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector) void
JdbcState.updateState
(List<TridentTuple> tuples, TridentCollector collector) void
JdbcUpdater.updateState
(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.jms.trident
Modifier and TypeMethodDescriptionvoid
JmsState.updateState
(List<TridentTuple> tuples, TridentCollector collector) void
JmsUpdater.updateState
(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.kafka.spout.trident
Modifier and TypeMethodDescriptionKafkaTridentOpaqueSpoutEmitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> lastPartitionMeta) void
KafkaTridentTransactionalSpoutEmitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> partitionMeta) KafkaTridentSpoutEmitter.emitPartitionBatchNew
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> lastBatch) Emit a new batch.KafkaTridentTransactionalSpoutEmitter.emitPartitionBatchNew
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> lastPartitionMeta) void
KafkaTridentSpoutEmitter.reEmitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> currBatch) Emit a batch that has already been emitted. -
Uses of TridentCollector in org.apache.storm.kafka.trident
Modifier and TypeMethodDescriptionvoid
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 TridentCollector in org.apache.storm.redis.trident
Modifier and TypeMethodDescriptionvoid
PrintFunction.execute
(TridentTuple tuple, TridentCollector tridentCollector) -
Uses of TridentCollector in org.apache.storm.redis.trident.state
Modifier and TypeMethodDescriptionvoid
AbstractRedisStateQuerier.execute
(TridentTuple tuple, List<Values> values, TridentCollector collector) void
AbstractRedisStateUpdater.updateState
(T state, List<TridentTuple> inputs, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.starter.spout
Modifier and TypeMethodDescriptionvoid
RandomNumberGeneratorSpout.emitBatch
(long batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.starter.trident
Modifier and TypeMethodDescriptionvoid
TridentReach.ExpandList.execute
(TridentTuple tuple, TridentCollector collector) void
TridentWordCount.Split.execute
(TridentTuple tuple, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.drpc
Modifier and TypeMethodDescriptionvoid
ReturnResultsReducer.complete
(ReturnResultsReducer.ReturnResultsState state, TridentCollector collector) void
ReturnResultsReducer.execute
(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector) ReturnResultsReducer.init
(TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation
Modifier and TypeMethodDescriptionvoid
Aggregator.aggregate
(T val, TridentTuple tuple, TridentCollector collector) void
Aggregator.complete
(T val, TridentCollector collector) void
GroupedMultiReducer.complete
(T state, TridentTuple group, TridentCollector collector) void
MultiReducer.complete
(T state, TridentCollector collector) 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) void
MultiReducer.execute
(T state, int streamIndex, TridentTuple input, TridentCollector collector) Aggregator.init
(Object batchId, TridentCollector collector) GroupedMultiReducer.init
(TridentCollector collector, TridentTuple group) MultiReducer.init
(TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation.builtin
Modifier and TypeMethodDescriptionvoid
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
ComparisonAggregator.complete
(ComparisonAggregator.State state, TridentCollector collector) void
FirstN.FirstNAgg.complete
(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentCollector collector) void
FirstN.FirstNSortedAgg.complete
(PriorityQueue val, 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) ComparisonAggregator.init
(Object batchId, TridentCollector collector) org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State
FirstN.FirstNAgg.init
(Object batchId, TridentCollector collector) FirstN.FirstNSortedAgg.init
(Object batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation.impl
Modifier and TypeMethodDescriptionvoid
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
ChainedAggregatorImpl.complete
(ChainedResult val, TridentCollector collector) void
CombinerAggregatorCombineImpl.complete
(Result val, TridentCollector collector) void
GroupedAggregator.complete
(Object[] arr, TridentCollector collector) void
GroupedMultiReducerExecutor.complete
(Map<TridentTuple, Object> state, TridentCollector collector) void
IdentityMultiReducer.complete
(T state, TridentCollector collector) void
JoinerMultiReducer.complete
(JoinState state, TridentTuple group, TridentCollector collector) void
PreservingFieldsOrderJoinerMultiReducer.complete
(JoinState state, TridentTuple group, TridentCollector collector) void
ReducerAggregatorImpl.complete
(Result val, TridentCollector collector) void
SingleEmitAggregator.complete
(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, 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) ChainedAggregatorImpl.init
(Object batchId, TridentCollector collector) CombinerAggregatorCombineImpl.init
(Object batchId, TridentCollector collector) Object[]
GroupedAggregator.init
(Object batchId, TridentCollector collector) GroupedMultiReducerExecutor.init
(TridentCollector collector) IdentityMultiReducer.init
(TridentCollector collector) JoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) PreservingFieldsOrderJoinerMultiReducer.init
(TridentCollector collector, TridentTuple group) ReducerAggregatorImpl.init
(Object batchId, TridentCollector collector) org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState
SingleEmitAggregator.init
(Object batchId, TridentCollector collector) void
CaptureCollector.setCollector
(TridentCollector coll) void
ChainedResult.setFollowThroughCollector
(TridentCollector collector) void
CombinerAggStateUpdater.updateState
(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector) void
ReducerAggStateUpdater.updateState
(Snapshottable state, List<TridentTuple> tuples, TridentCollector collector) ModifierConstructorDescriptionChainedResult
(TridentCollector collector, int size) GroupCollector
(TridentCollector collector, ComboList.Factory factory) -
Uses of TridentCollector in org.apache.storm.trident.planner.processor
-
Uses of TridentCollector in org.apache.storm.trident.spout
Modifier and TypeMethodDescriptionvoid
BatchSpoutExecutor.BatchSpoutEmitter.emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) void
IBatchSpout.emitBatch
(long batchId, TridentCollector collector) void
ITridentSpout.Emitter.emitBatch
(TransactionAttempt tx, X coordinatorMeta, TridentCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.void
OpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) IOpaquePartitionedTridentSpout.Emitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, PartitionT partition, M lastPartitionMeta) Emit a batch of tuples for a partition/transaction.void
IPartitionedTridentSpout.Emitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, PartitionT partition, X partitionMeta) Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.IPartitionedTridentSpout.Emitter.emitPartitionBatchNew
(TransactionAttempt tx, TridentCollector collector, PartitionT partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction that's never been emitted before. -
Uses of TridentCollector in org.apache.storm.trident.state
Modifier and TypeMethodDescriptionvoid
QueryFunction.execute
(TridentTuple tuple, T result, TridentCollector collector) void
StateUpdater.updateState
(S state, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.state.map
Modifier and TypeMethodDescriptionvoid
MapCombinerAggStateUpdater.updateState
(MapState map, List<TridentTuple> tuples, TridentCollector collector) void
MapReducerAggStateUpdater.updateState
(MapState map, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.testing
Modifier and TypeMethodDescriptionvoid
CountAsAggregator.aggregate
(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector) void
CountAsAggregator.complete
(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentCollector collector) void
FixedBatchSpout.emitBatch
(long batchId, TridentCollector collector) void
Split.execute
(TridentTuple tuple, TridentCollector collector) void
StringLength.execute
(TridentTuple tuple, TridentCollector collector) void
TuplifyArgs.execute
(TridentTuple input, TridentCollector collector) org.apache.storm.trident.testing.CountAsAggregator.State
CountAsAggregator.init
(Object batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.windowing
Modifier and TypeMethodDescriptionvoid
WindowsStateUpdater.updateState
(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)