Uses of Class
org.apache.storm.coordination.BatchOutputCollector
Packages that use BatchOutputCollector
Package
Description
-
Uses of BatchOutputCollector in org.apache.storm.coordination
Subclasses of BatchOutputCollector in org.apache.storm.coordinationMethods in org.apache.storm.coordination with parameters of type BatchOutputCollectorModifier and TypeMethodDescriptionvoidIBatchBolt.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, T id) -
Uses of BatchOutputCollector in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type BatchOutputCollectorModifier and TypeMethodDescriptionvoidReachTopology.CountAggregator.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) voidReachTopology.PartialUniquer.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector, Object id) -
Uses of BatchOutputCollector in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner with parameters of type BatchOutputCollectorModifier and TypeMethodDescriptionvoidSubtopologyBolt.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector batchCollector) Constructors in org.apache.storm.trident.planner with parameters of type BatchOutputCollector -
Uses of BatchOutputCollector in org.apache.storm.trident.planner.processor
Methods in org.apache.storm.trident.planner.processor that return BatchOutputCollectorConstructors in org.apache.storm.trident.planner.processor with parameters of type BatchOutputCollectorModifierConstructorDescriptionTridentContext(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
Methods in org.apache.storm.trident.spout with parameters of type BatchOutputCollectorModifier and TypeMethodDescriptionvoidTridentSpoutExecutor.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type BatchOutputCollectorModifier and TypeMethodDescriptionvoidITridentBatchBolt.prepare(Map<String, Object> conf, TopologyContext context, BatchOutputCollector collector) -
Uses of BatchOutputCollector in org.apache.storm.trident.windowing
Fields in org.apache.storm.trident.windowing declared as BatchOutputCollectorModifier and TypeFieldDescriptionprotected final BatchOutputCollectorAbstractTridentWindowManager.delegateCollectorConstructors in org.apache.storm.trident.windowing with parameters of type BatchOutputCollectorModifierConstructorDescriptionAbstractTridentWindowManager(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)