Uses of Class
org.apache.storm.coordination.BatchOutputCollector
Packages that use BatchOutputCollector
Package
Description
- 
Uses of BatchOutputCollector in org.apache.storm.coordinationSubclasses 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.starterMethods 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.plannerMethods 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.processorMethods 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.spoutMethods 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.topologyMethods 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.windowingFields 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)