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 void
ExclamationTopology.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 void
ClojureSpout. 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 void
DRPCSpout. 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 void
HdfsFileTopology.SentenceSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void
SequenceFileTopology.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 SpoutOutputCollector
HdfsSpout. getCollector()
Methods in org.apache.storm.hdfs.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description void
HdfsSpout. 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 void
BucketTestHiveTopology.UserDataSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void
HiveTopology.UserDataSpout. open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collector)
void
HiveTopologyPartitioned.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 void
UserSpout. 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 void
JmsSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector spoutOutputCollector)
ISpout
implementation. -
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 SpoutOutputCollector
KafkaSpout. collector
Methods in org.apache.storm.kafka.spout with parameters of type SpoutOutputCollector Modifier and Type Method Description void
KafkaSpout. 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 void
LambdaSpout. 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 void
LoadSpout. 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 void
ConstSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
FileReadSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
StringGenSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
WordGenSpout. 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 void
WordSpout. 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 void
CheckpointSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
ISpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster.void
ShellSpout. 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 void
SocketSpout. 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 void
IncrementingSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
TimeDataIncrementingSpout. 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 void
AnchoredWordCount.RandomSentenceSpout. open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void
BlobStoreAPIWordCountTopology.RandomSentenceSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
FastWordCountTopology.FastRandomSentenceSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
InOrderDeliveryTest.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 void
RandomIntegerSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
RandomSentenceSpout. 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 void
FeederSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
FixedTupleSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
PythonShellMetricsSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
SpoutTracker. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
TestEventLogSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
TestPlannerSpout. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
void
TestWordSpout. 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 void
RichSpoutBatchTriggerer. 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 void
MasterBatchCoordinator. open(Map<String,Object> conf, TopologyContext context, SpoutOutputCollector collector)
-