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

Packages that use OutputCollector

Package	Description
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.drpc
org.apache.storm.druid.bolt
org.apache.storm.elasticsearch.bolt
org.apache.storm.eventhubs.bolt
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.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.solr.bolt
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.transactional
org.apache.storm.trident.topology
org.apache.storm.utils

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 stormConf, 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	ExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	BaseExecutionResultHandler.onQuerySuccess(OutputCollector collector, Tuple tuple) Invoked when a query is executed with success.
void	ExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	BaseExecutionResultHandler.onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e, OutputCollector collector, Tuple tuple) Invoked when a QueryValidationException is thrown.
void	ExecutionResultHandler.onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a ReadTimeoutException is thrown.
void	BaseExecutionResultHandler.onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a ReadTimeoutException is thrown.
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, List<Tuple> tl)
void	ExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, Tuple i) Default method used to handle any type of exception.
void	AbstractExecutionResultHandler.onThrowable(Throwable t, OutputCollector collector, Tuple i)
void	ExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	BaseExecutionResultHandler.onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e, OutputCollector collector, Tuple tuple) Invoked when a UnavailableException is thrown.
void	ExecutionResultHandler.onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e, OutputCollector collector, Tuple tuple) Invoked when a WriteTimeoutException is thrown.
void	BaseExecutionResultHandler.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	BatchCassandraWriterBolt.prepare(Map stormConfig, TopologyContext topologyContext, OutputCollector outputCollector) Called when a task for this component is initialized within a worker on the cluster.
void	BaseCassandraBolt.prepare(Map stormConfig, 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	SingleAsyncResultHandler.flush(OutputCollector collector)
void	BatchAsyncResultHandler.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 stormConf, 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 config, TopologyContext context, OutputCollector collector)
void	BatchBoltExecutor.prepare(Map 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.drpc

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

Modifier and Type	Method and Description
void	ReturnResults.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	KeyedFairBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	JoinResult.prepare(Map map, TopologyContext context, OutputCollector collector)

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

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

Modifier and Type	Method and Description
void	DruidBeamBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector) Deprecated.

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	EsPercolateBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
void	EsIndexBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
void	AbstractEsBolt.prepare(Map 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 config, 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	HBaseLookupBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	HBaseBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	AbstractHBaseBolt.prepare(Map map, 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	SequenceFileBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
void	HdfsBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
protected void	AvroGenericRecordBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
protected abstract void	AbstractHdfsBolt.doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
void	SequenceFileTopology.MyBolt.prepare(Map config, TopologyContext context, OutputCollector collector)
void	HdfsFileTopology.MyBolt.prepare(Map config, TopologyContext context, OutputCollector collector)
void	AbstractHdfsBolt.prepare(Map 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 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 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	JdbcInsertBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
void	AbstractJdbcBolt.prepare(Map 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.

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 stormConf, 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 stormConf, 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 stormConf, TopologyContext context, OutputCollector collector) Deprecated.

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	SystemBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	MetricsConsumerBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	EventLoggerBolt.prepare(Map stormConf, 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 stormConf, TopologyContext context, OutputCollector collector)
void	AbstractMongoBolt.prepare(Map stormConf, 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 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 stormConf, 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 stormConf, TopologyContext context, OutputCollector collector)
void	DevNullBolt.prepare(Map stormConf, 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 stormConf, 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 stormConf, 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 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 stormConf, TopologyContext context, OutputCollector collector)
void	LookupWordCount.PrintWordTotalCountBolt.prepare(Map stormConf, 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 stormConf, 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 conf, TopologyContext context, OutputCollector collector)
void	MultipleLoggerTopology.ExclamationLoggingBolt.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	ExclamationTopology.ExclamationBolt.prepare(Map 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	SlidingWindowSumBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	SingleJoinBolt.prepare(Map conf, TopologyContext context, OutputCollector collector)
void	RollingCountBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	RollingCountAggBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

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 stormConf, TopologyContext context, OutputCollector collector)
void	IBolt.prepare(Map stormConf, 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 stormConf, TopologyContext context, OutputCollector collector)
void	TestPlannerBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestGlobalCount.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestEventOrderCheckBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	TestAggregatesCounter.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	PythonShellMetricsBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	NonRichBoltTracker.prepare(Map stormConf, 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	BaseStatefulBoltExecutor.init(TopologyContext context, OutputCollector collector)
void	WindowedBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	StatefulWindowedBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	StatefulBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	IWindowedBolt.prepare(Map stormConf, 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.
void	IStatefulBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)
void	CheckpointTupleForwarder.prepare(Map stormConf, TopologyContext context, OutputCollector outputCollector)
void	BasicBoltExecutor.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

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 stormConf, TopologyContext context, OutputCollector collector)
void	BaseStatefulBolt.prepare(Map stormConf, TopologyContext context, OutputCollector collector)

Uses of OutputCollector in org.apache.storm.transactional

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

Modifier and Type	Method and Description
void	TransactionalSpoutBatchExecutor.prepare(Map conf, 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 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)