Uses of Class
org.apache.storm.coordination.BatchOutputCollector
Package
Description
-
Uses of BatchOutputCollector in org.apache.storm.coordination
Modifier and TypeMethodDescriptionvoid
IBatchBolt.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, T id) -
Uses of BatchOutputCollector in org.apache.storm.starter
Modifier and TypeMethodDescriptionvoid
ReachTopology.CountAggregator.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) void
ReachTopology.PartialUniquer.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) -
Uses of BatchOutputCollector in org.apache.storm.trident.planner
Modifier and TypeMethodDescriptionvoid
SubtopologyBolt.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector batchCollector) -
Uses of BatchOutputCollector in org.apache.storm.trident.planner.processor
ModifierConstructorDescriptionTridentContext
(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.spout
Modifier and TypeMethodDescriptionvoid
TridentSpoutExecutor.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.topology
Modifier and TypeMethodDescriptionvoid
ITridentBatchBolt.prepare
(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.windowing
Modifier and TypeFieldDescriptionprotected final BatchOutputCollector
AbstractTridentWindowManager.delegateCollector
ModifierConstructorDescriptionAbstractTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector) InMemoryTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector) StoreBasedTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)