Uses of Class
org.apache.storm.coordination.BatchOutputCollector

Packages that use BatchOutputCollector

Package	Description
org.apache.storm.coordination
org.apache.storm.starter
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.spout
org.apache.storm.trident.topology
org.apache.storm.trident.windowing

Uses of BatchOutputCollector in org.apache.storm.coordination

Subclasses of BatchOutputCollector in org.apache.storm.coordination

Modifier and Type	Class	Description
class	BatchOutputCollectorImpl

Methods in org.apache.storm.coordination with parameters of type BatchOutputCollector

Modifier and Type	Method	Description
void	IBatchBolt.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 BatchOutputCollector

Modifier and Type	Method	Description
void	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

Methods in org.apache.storm.trident.planner with parameters of type BatchOutputCollector

Modifier and Type	Method	Description
void	SubtopologyBolt.prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector batchCollector)

Constructors in org.apache.storm.trident.planner with parameters of type BatchOutputCollector

Constructor	Description
BridgeReceiver(BatchOutputCollector collector)

Uses of BatchOutputCollector in org.apache.storm.trident.planner.processor

Methods in org.apache.storm.trident.planner.processor that return BatchOutputCollector

Modifier and Type	Method	Description
BatchOutputCollector	TridentContext.getDelegateCollector()

Constructors in org.apache.storm.trident.planner.processor with parameters of type BatchOutputCollector

Constructor	Description
TridentContext(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 BatchOutputCollector

Modifier and Type	Method	Description
void	TridentSpoutExecutor.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 BatchOutputCollector

Modifier and Type	Method	Description
void	ITridentBatchBolt.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 BatchOutputCollector

Modifier and Type	Field	Description
protected BatchOutputCollector	AbstractTridentWindowManager.delegateCollector

Constructors in org.apache.storm.trident.windowing with parameters of type BatchOutputCollector

Constructor	Description
AbstractTridentWindowManager(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)