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

Packages that use OutputCollector
Package
Description
org.apache.storm
org.apache.storm.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.drpc
org.apache.storm.flux.examples
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
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.perf.bolt
org.apache.storm.perf.utils
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
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
  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
  Description
  `void`
  JoinBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, 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
  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
  Description
  `void`
  BatchBoltExecutor.`prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)`
  `void`
  CoordinatedBolt.`prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)`
  Constructors in org.apache.storm.coordination with parameters of type OutputCollector
  Modifier
  Constructor
  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
  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
  Description
  `void`
  JoinResult.`prepare(Map<String,Object> map, TopologyContext context, OutputCollector collector)`
  `void`
  KeyedFairBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  ReturnResults.`prepare(Map<String,Object> topoConf, 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
  Description
  `void`
  StatefulWordCounter.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TestWindowBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, 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
  Description
  `protected OutputCollector`
  AbstractHdfsBolt.`collector`
  Methods in org.apache.storm.hdfs.bolt with parameters of type OutputCollector
  Modifier and Type
  Method
  Description
  `protected abstract void`
  AbstractHdfsBolt.`doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)`
  `protected void`
  AvroGenericRecordBolt.`doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)`
  `void`
  HdfsBolt.`doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)`
  `void`
  SequenceFileBolt.`doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)`
  `final void`
  AbstractHdfsBolt.`prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)`
  Marked as final to prevent override.
  `void`
  HdfsFileTopology.MyBolt.`prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)`
  `void`
  SequenceFileTopology.MyBolt.`prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)`

- ## 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
  Description
  `void`
  HdfsSpoutTopology.ConstBolt.`prepare(Map<String,Object> conf, TopologyContext context, 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
  Description
  `protected OutputCollector`
  AbstractJdbcBolt.`collector`
  Methods in org.apache.storm.jdbc.bolt with parameters of type OutputCollector
  Modifier and Type
  Method
  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
  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
  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
  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
  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
  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
  Description
  `void`
  EventLoggerBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  MetricsConsumerBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  SystemBolt.`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
  Description
  `void`
  DevNullBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  IdBolt.`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
  Description
  `void`
  IdentityBolt.`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
  Description
  `protected OutputCollector`
  AbstractRedisBolt.`collector`
  Methods in org.apache.storm.redis.bolt with parameters of type OutputCollector
  Modifier and Type
  Method
  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
  Description
  `void`
  LookupWordCount.PrintWordTotalCountBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  WhitelistWordCount.PrintWordTotalCountBolt.`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
  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
  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
  Description
  `void`
  ExclamationTopology.ExclamationBolt.`prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)`
  `void`
  MultipleLoggerTopology.ExclamationLoggingBolt.`prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)`
  `void`
  MultiThreadWordCountTopology.MultiThreadedSplitSentence.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  ResourceAwareExampleTopology.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
  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
  Modifier
  Constructor
  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
  Description
  `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.
  `void`
  ShellBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`

- ## Uses of OutputCollector in org.apache.storm.testing

  Methods in org.apache.storm.testing with parameters of type OutputCollector
  Modifier and Type
  Method
  Description
  `void`
  NonRichBoltTracker.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  PythonShellMetricsBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TestAggregatesCounter.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TestEventOrderCheckBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TestGlobalCount.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TestPlannerBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  TupleCaptureBolt.`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
  Description
  `protected static class`
  `BaseStatefulBoltExecutor.AnchoringOutputCollector`
  Fields in org.apache.storm.topology declared as OutputCollector
  Modifier and Type
  Field
  Description
  `protected OutputCollector`
  BaseStatefulBoltExecutor.`collector`
  Methods in org.apache.storm.topology with parameters of type OutputCollector
  Modifier and Type
  Method
  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`
  BasicBoltExecutor.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  CheckpointTupleForwarder.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector outputCollector)`
  `void`
  IStatefulBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  Analogue to bolt function.
  `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.
  `void`
  PersistentWindowedBoltExecutor.`prepare(Map<String,Object> topoConf, 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`
  WindowedBoltExecutor.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  Constructors in org.apache.storm.topology with parameters of type OutputCollector
  Modifier
  Constructor
  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
  Description
  `void`
  BaseStatefulBolt.`prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)`
  `void`
  BaseWindowedBolt.`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
  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
  Modifier
  Constructor
  Description
  ``
  `BatchHelper(int batchSize, OutputCollector collector)`