Uses of Class
org.apache.storm.task.OutputCollector

Packages that use OutputCollector

Package	Description
org.apache.storm
org.apache.storm.bolt
org.apache.storm.cassandra
org.apache.storm.cassandra.bolt
org.apache.storm.cassandra.executor
org.apache.storm.cassandra.executor.impl
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.eventhubs.bolt
org.apache.storm.flux.examples
org.apache.storm.hbase.bolt
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.hive.bolt
org.apache.storm.jdbc.bolt
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.loadgen
org.apache.storm.metric
org.apache.storm.mongodb.bolt
org.apache.storm.mqtt.bolt
org.apache.storm.opentsdb.bolt
org.apache.storm.perf.bolt
org.apache.storm.perf.utils
org.apache.storm.pmml
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
org.apache.storm.rocketmq.bolt
org.apache.storm.solr.bolt
org.apache.storm.sql.runtime.datasource.socket.bolt
org.apache.storm.st.topology.window
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.streams.processors
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident.topology
org.apache.storm.utils

Uses of OutputCollector in org.apache.storm

Methods in org.apache.storm with parameters of type OutputCollector

Modifier and Type	Method and Description
void	ExclamationTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.bolt

Methods in org.apache.storm.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	JoinBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.cassandra

Methods in org.apache.storm.cassandra with parameters of type OutputCollector

Modifier and Type	Method and Description
protected void	BaseExecutionResultHandler.onDriverException(com.datastax.driver.core.exceptions.DriverException e, OutputCollector collector, Tuple tuple) This method is called when an one of the methods of the BaseExecutionResultHandler is not overridden.
void	BaseExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	ExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	BaseExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	ExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	BaseExecutionResultHandler.onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a ReadTimeoutException is thrown.
void	ExecutionResultHandler.onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a ReadTimeoutException is thrown.
void	AbstractExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl)
void	ExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl) Default method used to handle any type of exception.
void	AbstractExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, Tuple i)
void	ExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, Tuple i) Default method used to handle any type of exception.
void	BaseExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	ExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	BaseExecutionResultHandler.onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a WriteTimeoutException is thrown.
void	ExecutionResultHandler.onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a WriteTimeoutException is thrown.

Uses of OutputCollector in org.apache.storm.cassandra.bolt

Fields in org.apache.storm.cassandra.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	BaseCassandraBolt.outputCollector

Methods in org.apache.storm.cassandra.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	BaseCassandraBolt.prepare(Map<String,Object> topoConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.
void	BatchCassandraWriterBolt.prepare(Map<String,Object> topoConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.

Uses of OutputCollector in org.apache.storm.cassandra.executor

Methods in org.apache.storm.cassandra.executor with parameters of type OutputCollector

Modifier and Type	Method and Description
void	AsyncResultHandler.flush(OutputCollector collector)
void	ExecutionResultCollector.handle(OutputCollector collector, ExecutionResultHandler handler)
void	ExecutionResultCollector.SucceedCollector.handle(OutputCollector collector, ExecutionResultHandler handler) Calls ExecutionResultHandler.onQuerySuccess(org.apache.storm.task.OutputCollector, org.apache.storm.tuple.Tuple) before acknowledging an single input tuple.
void	ExecutionResultCollector.FailedCollector.handle(OutputCollector collector, ExecutionResultHandler handler) Calls ExecutionResultHandler.onThrowable(Throwable, org.apache.storm.task.OutputCollector, org.apache.storm.tuple.Tuple) .

Uses of OutputCollector in org.apache.storm.cassandra.executor.impl

Methods in org.apache.storm.cassandra.executor.impl with parameters of type OutputCollector

Modifier and Type	Method and Description
void	BatchAsyncResultHandler.flush(OutputCollector collector)
void	SingleAsyncResultHandler.flush(OutputCollector collector)

Uses of OutputCollector in org.apache.storm.clojure

Methods in org.apache.storm.clojure with parameters of type OutputCollector

Modifier and Type	Method and Description
void	ClojureBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.coordination

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

Modifier and Type	Method and Description
void	CoordinatedBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	BatchBoltExecutor.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Constructors in org.apache.storm.coordination with parameters of type OutputCollector

Constructor and Description
BatchOutputCollectorImpl(OutputCollector collector)

Uses of OutputCollector in org.apache.storm.daemon

Methods in org.apache.storm.daemon with parameters of type OutputCollector

Modifier and Type	Method and Description
void	Acker.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.drpc

Methods in org.apache.storm.drpc with parameters of type OutputCollector

Modifier and Type	Method and Description
void	KeyedFairBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	ReturnResults.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	JoinResult.prepare(Map<String,Object> map, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.elasticsearch.bolt

Fields in org.apache.storm.elasticsearch.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractEsBolt.collector

Methods in org.apache.storm.elasticsearch.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	EsIndexBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)
void	AbstractEsBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)
void	EsPercolateBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)

Uses of OutputCollector in org.apache.storm.eventhubs.bolt

Fields in org.apache.storm.eventhubs.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	EventHubBolt.collector

Methods in org.apache.storm.eventhubs.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	EventHubBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.flux.examples

Methods in org.apache.storm.flux.examples with parameters of type OutputCollector

Modifier and Type	Method and Description
void	TestWindowBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	StatefulWordCounter.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.hbase.bolt

Fields in org.apache.storm.hbase.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractHBaseBolt.collector

Methods in org.apache.storm.hbase.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	HBaseBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector)
void	HBaseLookupBolt.prepare(Map<String,Object> config, TopologyContext topologyContext, OutputCollector collector)
void	AbstractHBaseBolt.prepare(Map<String,Object> topoConf, TopologyContext topologyContext, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.hdfs.bolt

Fields in org.apache.storm.hdfs.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractHdfsBolt.collector

Methods in org.apache.storm.hdfs.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	HdfsBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
protected void	AvroGenericRecordBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
protected abstract void	AbstractHdfsBolt.doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileTopology.MyBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	HdfsFileTopology.MyBolt.prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)
void	AbstractHdfsBolt.prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector) Marked as final to prevent override.

Uses of OutputCollector in org.apache.storm.hdfs.spout

Methods in org.apache.storm.hdfs.spout with parameters of type OutputCollector

Modifier and Type	Method and Description
void	HdfsSpoutTopology.ConstBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.hive.bolt

Methods in org.apache.storm.hive.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	HiveBolt.prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.jdbc.bolt

Fields in org.apache.storm.jdbc.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractJdbcBolt.collector

Methods in org.apache.storm.jdbc.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	AbstractJdbcBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector) Subclasses should call this to ensure output collector and connection provider are set up, and finally jdbcClient is initialized properly.
void	JdbcInsertBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.jms.bolt

Methods in org.apache.storm.jms.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	JmsBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Initializes JMS resources.

Uses of OutputCollector in org.apache.storm.jms.example

Methods in org.apache.storm.jms.example with parameters of type OutputCollector

Modifier and Type	Method and Description
void	GenericBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.kafka.bolt

Methods in org.apache.storm.kafka.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	KafkaBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.kafka.spout

Methods in org.apache.storm.kafka.spout with parameters of type OutputCollector

Modifier and Type	Method and Description
void	KafkaSpoutTestBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.loadgen

Methods in org.apache.storm.loadgen with parameters of type OutputCollector

Modifier and Type	Method and Description
void	LoadBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.metric

Methods in org.apache.storm.metric with parameters of type OutputCollector

Modifier and Type	Method and Description
void	MetricsConsumerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	SystemBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	EventLoggerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.mongodb.bolt

Fields in org.apache.storm.mongodb.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractMongoBolt.collector

Methods in org.apache.storm.mongodb.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	MongoInsertBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	AbstractMongoBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.mqtt.bolt

Methods in org.apache.storm.mqtt.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	MqttBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.opentsdb.bolt

Methods in org.apache.storm.opentsdb.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	OpenTsdbBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.perf.bolt

Methods in org.apache.storm.perf.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	IdBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	DevNullBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.perf.utils

Methods in org.apache.storm.perf.utils with parameters of type OutputCollector

Modifier and Type	Method and Description
void	IdentityBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.pmml

Methods in org.apache.storm.pmml with parameters of type OutputCollector

Modifier and Type	Method and Description
void	PMMLPredictorBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.redis.bolt

Fields in org.apache.storm.redis.bolt declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	AbstractRedisBolt.collector

Methods in org.apache.storm.redis.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	AbstractRedisBolt.prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.

Uses of OutputCollector in org.apache.storm.redis.topology

Methods in org.apache.storm.redis.topology with parameters of type OutputCollector

Modifier and Type	Method and Description
void	WhitelistWordCount.PrintWordTotalCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	LookupWordCount.PrintWordTotalCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.rocketmq.bolt

Methods in org.apache.storm.rocketmq.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	RocketMqBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.solr.bolt

Methods in org.apache.storm.solr.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	SolrUpdateBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.sql.runtime.datasource.socket.bolt

Methods in org.apache.storm.sql.runtime.datasource.socket.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	SocketBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.st.topology.window

Methods in org.apache.storm.st.topology.window with parameters of type OutputCollector

Modifier and Type	Method and Description
void	TimeDataVerificationBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	VerificationBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.starter

Methods in org.apache.storm.starter with parameters of type OutputCollector

Modifier and Type	Method and Description
void	ResourceAwareExampleTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	MultipleLoggerTopology.ExclamationLoggingBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	ExclamationTopology.ExclamationBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.starter.bolt

Methods in org.apache.storm.starter.bolt with parameters of type OutputCollector

Modifier and Type	Method and Description
void	RollingCountAggBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	RollingCountBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	SingleJoinBolt.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)
void	SlidingWindowSumBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.streams.processors

Constructors in org.apache.storm.streams.processors with parameters of type OutputCollector

Constructor and Description
EmittingProcessorContext(ProcessorNode processorNode, OutputCollector collector, String outputStreamId)

Uses of OutputCollector in org.apache.storm.task

Methods in org.apache.storm.task with parameters of type OutputCollector

Modifier and Type	Method and Description
void	ShellBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.

Uses of OutputCollector in org.apache.storm.testing

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

Modifier and Type	Method and Description
void	TupleCaptureBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	NonRichBoltTracker.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestPlannerBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestAggregatesCounter.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	PythonShellMetricsBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestGlobalCount.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	TestEventOrderCheckBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.topology

Subclasses of OutputCollector in org.apache.storm.topology

Modifier and Type	Class and Description
protected static class	BaseStatefulBoltExecutor.AnchoringOutputCollector

Fields in org.apache.storm.topology declared as OutputCollector

Modifier and Type	Field and Description
protected OutputCollector	BaseStatefulBoltExecutor.collector

Methods in org.apache.storm.topology with parameters of type OutputCollector

Modifier and Type	Method and Description
protected void	WindowedBoltExecutor.doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)
protected void	BaseStatefulBoltExecutor.init(TopologyContext context, OutputCollector collector)
void	StatefulBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	StatefulWindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IStatefulBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) Analogue to bolt function.
void	PersistentWindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	BasicBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	CheckpointTupleForwarder.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector outputCollector)
void	WindowedBoltExecutor.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	IWindowedBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector) This is similar to the IBolt.prepare(Map, TopologyContext, OutputCollector) except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.

Constructors in org.apache.storm.topology with parameters of type OutputCollector

Constructor and Description
BasicOutputCollector(OutputCollector out)

Uses of OutputCollector in org.apache.storm.topology.base

Methods in org.apache.storm.topology.base with parameters of type OutputCollector

Modifier and Type	Method and Description
void	BaseWindowedBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)
void	BaseStatefulBolt.prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.trident.topology

Methods in org.apache.storm.trident.topology with parameters of type OutputCollector

Modifier and Type	Method and Description
void	TridentBoltExecutor.prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.utils

Constructors in org.apache.storm.utils with parameters of type OutputCollector

Constructor and Description
BatchHelper(int batchSize, OutputCollector collector)