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.testing
org.apache.storm.transactional
org.apache.storm.transactional.partitioned
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 and Description
class	BatchOutputCollectorImpl

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

Modifier and Type	Method and Description
void	IBatchBolt.prepare(Map 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 and Description
void	TransactionalGlobalCount.BatchCount.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ReachTopology.PartialUniquer.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	ReachTopology.CountAggregator.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	TransactionalWords.KeyedCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)
void	TransactionalWords.BucketCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)
void	TransactionalGlobalCount.UpdateGlobalCount.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)

Uses of BatchOutputCollector in org.apache.storm.testing

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

Modifier and Type	Method and Description
void	KeyedSummingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	KeyedCountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	CountingBatchBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	BatchNumberList.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, Object id)
void	CountingCommitBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)

Uses of BatchOutputCollector in org.apache.storm.transactional

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

Modifier and Type	Method and Description
void	ITransactionalSpout.Emitter.emitBatch(TransactionAttempt tx, X coordinatorMeta, BatchOutputCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.

Uses of BatchOutputCollector in org.apache.storm.transactional.partitioned

Methods in org.apache.storm.transactional.partitioned with parameters of type BatchOutputCollector

Modifier and Type	Method and Description
void	OpaquePartitionedTransactionalSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, BatchOutputCollector collector)
void	IPartitionedTransactionalSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int 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.
X	IOpaquePartitionedTransactionalSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction.
X	IPartitionedTransactionalSpout.Emitter.emitPartitionBatchNew(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction that’s never been emitted before.

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 and Description
void	SubtopologyBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector batchCollector)

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

Constructor and 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 and Description
BatchOutputCollector	TridentContext.getDelegateCollector()

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

Constructor and 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 and Description
void	TridentSpoutExecutor.prepare(Map 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 and Description
void	ITridentBatchBolt.prepare(Map 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 and Description
protected BatchOutputCollector	AbstractTridentWindowManager.delegateCollector

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

Constructor and 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)