Uses of Class
org.apache.storm.task.OutputCollector
-
-
Uses of OutputCollector in org.apache.storm
Methods in org.apache.storm with parameters of type OutputCollector Modifier and Type Method Description voidExclamationTopology.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 voidJoinBolt. 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 voidClojureBolt. 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 voidBatchBoltExecutor. prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)voidCoordinatedBolt. prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)Constructors in org.apache.storm.coordination with parameters of type OutputCollector 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 voidAcker. 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 voidJoinResult. prepare(Map<String,Object> map, TopologyContext context, OutputCollector collector)voidKeyedFairBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidReturnResults. 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 voidStatefulWordCounter. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTestWindowBolt. 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 OutputCollectorAbstractHdfsBolt. collectorMethods in org.apache.storm.hdfs.bolt with parameters of type OutputCollector Modifier and Type Method Description protected abstract voidAbstractHdfsBolt. doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)protected voidAvroGenericRecordBolt. doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)voidHdfsBolt. doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)voidSequenceFileBolt. doPrepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)voidAbstractHdfsBolt. prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)Marked as final to prevent override.voidHdfsFileTopology.MyBolt. prepare(Map<String,Object> config, TopologyContext context, OutputCollector collector)voidSequenceFileTopology.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 voidHdfsSpoutTopology.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 Description voidHiveBolt. prepare(Map<String,Object> conf, TopologyContext topologyContext, OutputCollector collector)Deprecated, for removal: This API element is subject to removal in a future version. -
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 OutputCollectorAbstractJdbcBolt. collectorMethods in org.apache.storm.jdbc.bolt with parameters of type OutputCollector Modifier and Type Method Description voidAbstractJdbcBolt. 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.voidJdbcInsertBolt. 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 voidJmsBolt. 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 voidGenericBolt. 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 voidKafkaBolt. 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 voidKafkaSpoutTestBolt. 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 voidLoadBolt. 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 voidEventLoggerBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidMetricsConsumerBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidSystemBolt. 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 voidDevNullBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidIdBolt. 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 voidIdentityBolt. 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 OutputCollectorAbstractRedisBolt. collectorMethods in org.apache.storm.redis.bolt with parameters of type OutputCollector Modifier and Type Method Description voidAbstractRedisBolt. 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 voidLookupWordCount.PrintWordTotalCountBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidWhitelistWordCount.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 voidSocketBolt. 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 voidTimeDataVerificationBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidVerificationBolt. 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 voidExclamationTopology.ExclamationBolt. prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)voidMultipleLoggerTopology.ExclamationLoggingBolt. prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)voidMultiThreadWordCountTopology.MultiThreadedSplitSentence. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidResourceAwareExampleTopology.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 voidRollingCountAggBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidRollingCountBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidSingleJoinBolt. prepare(Map<String,Object> conf, TopologyContext context, OutputCollector collector)voidSlidingWindowSumBolt. 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 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 voidIBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)Called when a task for this component is initialized within a worker on the cluster.voidShellBolt. 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 voidNonRichBoltTracker. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidPythonShellMetricsBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTestAggregatesCounter. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTestEventOrderCheckBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTestGlobalCount. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTestPlannerBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidTupleCaptureBolt. 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 classBaseStatefulBoltExecutor.AnchoringOutputCollectorFields in org.apache.storm.topology declared as OutputCollector Modifier and Type Field Description protected OutputCollectorBaseStatefulBoltExecutor. collectorMethods in org.apache.storm.topology with parameters of type OutputCollector Modifier and Type Method Description protected voidWindowedBoltExecutor. doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)protected voidBaseStatefulBoltExecutor. init(TopologyContext context, OutputCollector collector)voidBasicBoltExecutor. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidCheckpointTupleForwarder. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector outputCollector)voidIStatefulBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)Analogue to bolt function.voidIWindowedBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)This is similar to theIBolt.prepare(Map, TopologyContext, OutputCollector)except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow.voidPersistentWindowedBoltExecutor. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidStatefulBoltExecutor. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidStatefulWindowedBoltExecutor. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidWindowedBoltExecutor. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)Constructors in org.apache.storm.topology with parameters of type OutputCollector 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 voidBaseStatefulBolt. prepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector)voidBaseWindowedBolt. 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 voidTridentBoltExecutor. 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 Description BatchHelper(int batchSize, OutputCollector collector)
-