Uses of Class
org.apache.storm.spout.SpoutOutputCollector
-
-
Uses of SpoutOutputCollector in org.apache.storm
Methods in org.apache.storm with parameters of type SpoutOutputCollector Modifier and Type Method Description voidExclamationTopology.FixedOrderWordSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.clojure
Methods in org.apache.storm.clojure with parameters of type SpoutOutputCollector Modifier and Type Method Description voidClojureSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.drpc
Methods in org.apache.storm.drpc with parameters of type SpoutOutputCollector Modifier and Type Method Description voidDRPCSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.hdfs.bolt
Methods in org.apache.storm.hdfs.bolt with parameters of type SpoutOutputCollector Modifier and Type Method Description voidHdfsFileTopology.SentenceSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)voidSequenceFileTopology.SentenceSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.hdfs.spout
Methods in org.apache.storm.hdfs.spout that return SpoutOutputCollector Modifier and Type Method Description SpoutOutputCollectorHdfsSpout. getCollector()Methods in org.apache.storm.hdfs.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidHdfsSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.hive.bolt
Methods in org.apache.storm.hive.bolt with parameters of type SpoutOutputCollector Modifier and Type Method Description voidBucketTestHiveTopology.UserDataSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)voidHiveTopology.UserDataSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)voidHiveTopologyPartitioned.UserDataSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.jdbc.spout
Methods in org.apache.storm.jdbc.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidUserSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.jms.spout
Methods in org.apache.storm.jms.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidJmsSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector spoutOutputCollector)ISpoutimplementation. -
Uses of SpoutOutputCollector in org.apache.storm.kafka.spout
Fields in org.apache.storm.kafka.spout declared as SpoutOutputCollector Modifier and Type Field Description protected SpoutOutputCollectorKafkaSpout. collectorMethods in org.apache.storm.kafka.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidKafkaSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.lambda
Methods in org.apache.storm.lambda with parameters of type SpoutOutputCollector Modifier and Type Method Description voidLambdaSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen with parameters of type SpoutOutputCollector Modifier and Type Method Description voidLoadSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.perf.spout
Methods in org.apache.storm.perf.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidConstSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidFileReadSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidStringGenSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidWordGenSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.redis.topology
Methods in org.apache.storm.redis.topology with parameters of type SpoutOutputCollector Modifier and Type Method Description voidWordSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.spout
Methods in org.apache.storm.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidCheckpointSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidISpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)Called when a task for this component is initialized within a worker on the cluster.voidShellSpout. open(Map<String,Object> topoConf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.sql.runtime.datasource.socket.spout
Methods in org.apache.storm.sql.runtime.datasource.socket.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidSocketSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.st.topology.window
Methods in org.apache.storm.st.topology.window with parameters of type SpoutOutputCollector Modifier and Type Method Description voidIncrementingSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidTimeDataIncrementingSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type SpoutOutputCollector Modifier and Type Method Description voidAnchoredWordCount.RandomSentenceSpout. open(Map conf, TopologyContext context, SpoutOutputCollector collector)voidBlobStoreAPIWordCountTopology.RandomSentenceSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidFastWordCountTopology.FastRandomSentenceSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidInOrderDeliveryTest.InOrderSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.starter.spout
Methods in org.apache.storm.starter.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidRandomIntegerSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidRandomSentenceSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.testing
Methods in org.apache.storm.testing with parameters of type SpoutOutputCollector Modifier and Type Method Description voidFeederSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidFixedTupleSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidPythonShellMetricsSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidSpoutTracker. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidTestEventLogSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidTestPlannerSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)voidTestWordSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description voidRichSpoutBatchTriggerer. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector) -
Uses of SpoutOutputCollector in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type SpoutOutputCollector Modifier and Type Method Description voidMasterBatchCoordinator. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
-