Uses of Interface
org.apache.storm.trident.operation.TridentCollector
-
-
Uses of TridentCollector in org.apache.storm.hdfs.trident
Methods in org.apache.storm.hdfs.trident with parameters of type TridentCollector Modifier and Type Method Description voidFixedBatchSpout. emitBatch(long batchId, TridentCollector collector)voidHdfsState. updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)voidHdfsUpdater. updateState(HdfsState state, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.hive.trident
Methods in org.apache.storm.hive.trident with parameters of type TridentCollector Modifier and Type Method Description voidTridentHiveTopology.FixedBatchSpout. emitBatch(long batchId, TridentCollector collector)voidHiveState. updateState(List<TridentTuple> tuples, TridentCollector collector)Deprecated, for removal: This API element is subject to removal in a future version.voidHiveUpdater. updateState(HiveState state, List<TridentTuple> tuples, TridentCollector collector)Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of TridentCollector in org.apache.storm.jdbc.trident.state
Methods in org.apache.storm.jdbc.trident.state with parameters of type TridentCollector Modifier and Type Method Description voidJdbcQuery. execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)voidJdbcState. updateState(List<TridentTuple> tuples, TridentCollector collector)voidJdbcUpdater. updateState(JdbcState jdbcState, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.jms.trident
Methods in org.apache.storm.jms.trident with parameters of type TridentCollector Modifier and Type Method Description voidJmsState. updateState(List<TridentTuple> tuples, TridentCollector collector)voidJmsUpdater. updateState(JmsState jmsState, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.kafka.spout.trident
-
Uses of TridentCollector in org.apache.storm.kafka.trident
Methods in org.apache.storm.kafka.trident with parameters of type TridentCollector Modifier and Type Method Description voidTridentKafkaState. 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 TridentCollector in org.apache.storm.redis.trident
Methods in org.apache.storm.redis.trident with parameters of type TridentCollector Modifier and Type Method Description voidPrintFunction. execute(TridentTuple tuple, TridentCollector tridentCollector) -
Uses of TridentCollector in org.apache.storm.redis.trident.state
Methods in org.apache.storm.redis.trident.state with parameters of type TridentCollector Modifier and Type Method Description voidAbstractRedisStateQuerier. execute(TridentTuple tuple, List<Values> values, TridentCollector collector)voidAbstractRedisStateUpdater. updateState(T state, List<TridentTuple> inputs, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.starter.spout
Methods in org.apache.storm.starter.spout with parameters of type TridentCollector Modifier and Type Method Description voidRandomNumberGeneratorSpout. emitBatch(long batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.starter.trident
Methods in org.apache.storm.starter.trident with parameters of type TridentCollector Modifier and Type Method Description voidTridentReach.ExpandList. execute(TridentTuple tuple, TridentCollector collector)voidTridentWordCount.Split. execute(TridentTuple tuple, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.drpc
Methods in org.apache.storm.trident.drpc with parameters of type TridentCollector Modifier and Type Method Description voidReturnResultsReducer. complete(ReturnResultsReducer.ReturnResultsState state, TridentCollector collector)voidReturnResultsReducer. execute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)ReturnResultsReducer.ReturnResultsStateReturnResultsReducer. init(TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation
Methods in org.apache.storm.trident.operation with parameters of type TridentCollector Modifier and Type Method Description voidAggregator. aggregate(T val, TridentTuple tuple, TridentCollector collector)voidAggregator. complete(T val, TridentCollector collector)voidGroupedMultiReducer. complete(T state, TridentTuple group, TridentCollector collector)voidMultiReducer. complete(T state, TridentCollector collector)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)voidMultiReducer. execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)TAggregator. init(Object batchId, TridentCollector collector)TGroupedMultiReducer. init(TridentCollector collector, TridentTuple group)TMultiReducer. init(TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation.builtin
Methods in org.apache.storm.trident.operation.builtin with parameters of type TridentCollector Modifier and Type Method Description voidComparisonAggregator. 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)voidComparisonAggregator. complete(ComparisonAggregator.State state, TridentCollector collector)voidFirstN.FirstNAgg. complete(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentCollector collector)voidFirstN.FirstNSortedAgg. complete(PriorityQueue val, 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)ComparisonAggregator.StateComparisonAggregator. init(Object batchId, TridentCollector collector)org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.StateFirstN.FirstNAgg. init(Object batchId, TridentCollector collector)PriorityQueueFirstN.FirstNSortedAgg. init(Object batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.operation.impl
Classes in org.apache.storm.trident.operation.impl that implement TridentCollector Modifier and Type Class Description classCaptureCollectorclassGroupCollectorMethods in org.apache.storm.trident.operation.impl with parameters of type TridentCollector Modifier and Type Method Description voidChainedAggregatorImpl. 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)voidChainedAggregatorImpl. complete(ChainedResult val, TridentCollector collector)voidCombinerAggregatorCombineImpl. complete(Result val, TridentCollector collector)voidGroupedAggregator. complete(Object[] arr, TridentCollector collector)voidGroupedMultiReducerExecutor. complete(Map<TridentTuple,Object> state, TridentCollector collector)voidIdentityMultiReducer. complete(T state, TridentCollector collector)voidJoinerMultiReducer. complete(JoinState state, TridentTuple group, TridentCollector collector)voidPreservingFieldsOrderJoinerMultiReducer. complete(JoinState state, TridentTuple group, TridentCollector collector)voidReducerAggregatorImpl. complete(Result val, TridentCollector collector)voidSingleEmitAggregator. complete(org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val, 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)ChainedResultChainedAggregatorImpl. init(Object batchId, TridentCollector collector)ResultCombinerAggregatorCombineImpl. init(Object batchId, TridentCollector collector)Object[]GroupedAggregator. init(Object batchId, TridentCollector collector)Map<TridentTuple,Object>GroupedMultiReducerExecutor. init(TridentCollector collector)TIdentityMultiReducer. init(TridentCollector collector)JoinStateJoinerMultiReducer. init(TridentCollector collector, TridentTuple group)JoinStatePreservingFieldsOrderJoinerMultiReducer. init(TridentCollector collector, TridentTuple group)ResultReducerAggregatorImpl. init(Object batchId, TridentCollector collector)org.apache.storm.trident.operation.impl.SingleEmitAggregator.SingleEmitStateSingleEmitAggregator. init(Object batchId, TridentCollector collector)voidCaptureCollector. setCollector(TridentCollector coll)voidChainedResult. setFollowThroughCollector(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 TridentCollector Constructor Description ChainedResult(TridentCollector collector, int size)GroupCollector(TridentCollector collector, ComboList.Factory factory) -
Uses of TridentCollector in org.apache.storm.trident.planner.processor
Classes in org.apache.storm.trident.planner.processor that implement TridentCollector Modifier and Type Class Description classAppendCollectorclassFreshCollector -
Uses of TridentCollector in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout with parameters of type TridentCollector Modifier and Type Method Description voidBatchSpoutExecutor.BatchSpoutEmitter. emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)voidIBatchSpout. emitBatch(long batchId, TridentCollector collector)voidITridentSpout.Emitter. emitBatch(TransactionAttempt tx, X coordinatorMeta, TridentCollector collector)Emit a batch for the specified transaction attempt and metadata for the transaction.voidOpaquePartitionedTridentSpoutExecutor.Emitter. emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)Map<PartitionT,M>IOpaquePartitionedTridentSpout.Emitter. emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,M> lastBatchMetaMap)Emit a batch of tuples for a list of partitions/transactions.Map<PartitionT,X>IPartitionedTridentSpout.Emitter. emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,X> lastPartitionMetaMap)Emit a batch of tuples for the partitions that's never been emitted before.voidIPartitionedTridentSpout.Emitter. reEmitPartitionBatch(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. -
Uses of TridentCollector in org.apache.storm.trident.state
Methods in org.apache.storm.trident.state with parameters of type TridentCollector Modifier and Type Method Description voidQueryFunction. execute(TridentTuple tuple, T result, TridentCollector collector)voidStateUpdater. updateState(S state, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.state.map
Methods in org.apache.storm.trident.state.map with parameters of type TridentCollector Modifier and Type Method Description voidMapCombinerAggStateUpdater. updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector)voidMapReducerAggStateUpdater. updateState(MapState map, List<TridentTuple> tuples, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.testing
Methods in org.apache.storm.trident.testing with parameters of type TridentCollector Modifier and Type Method Description voidCountAsAggregator. aggregate(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentTuple tuple, TridentCollector collector)voidCountAsAggregator. complete(org.apache.storm.trident.testing.CountAsAggregator.State state, TridentCollector collector)voidFixedBatchSpout. emitBatch(long batchId, TridentCollector collector)voidSplit. execute(TridentTuple tuple, TridentCollector collector)voidStringLength. execute(TridentTuple tuple, TridentCollector collector)voidTuplifyArgs. execute(TridentTuple input, TridentCollector collector)org.apache.storm.trident.testing.CountAsAggregator.StateCountAsAggregator. init(Object batchId, TridentCollector collector) -
Uses of TridentCollector in org.apache.storm.trident.windowing
Methods in org.apache.storm.trident.windowing with parameters of type TridentCollector Modifier and Type Method Description voidWindowsStateUpdater. updateState(WindowsState state, List<TridentTuple> tuples, TridentCollector collector)
-