Uses of Class
org.apache.storm.spout.SpoutOutputCollector

Packages that use SpoutOutputCollector

Package	Description
org.apache.storm.clojure
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt
org.apache.storm.eventhubs.spout
org.apache.storm.hbase.topology
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.hive.bolt
org.apache.storm.jdbc.spout
org.apache.storm.jms.spout
org.apache.storm.kafka
org.apache.storm.kafka.spout
org.apache.storm.kinesis.spout
org.apache.storm.mongodb.topology
org.apache.storm.mqtt.spout
org.apache.storm.opentsdb
org.apache.storm.perf.spout
org.apache.storm.pmml
org.apache.storm.redis.topology
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.starter
org.apache.storm.starter.spout
org.apache.storm.testing
org.apache.storm.transactional
org.apache.storm.trident.spout
org.apache.storm.trident.topology

Uses of SpoutOutputCollector in org.apache.storm.clojure

Methods in org.apache.storm.clojure with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	ClojureSpout.open(Map 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 and Description
void	DRPCSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.elasticsearch.bolt

Methods in org.apache.storm.elasticsearch.bolt with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	EsIndexTopology.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.eventhubs.spout

Methods in org.apache.storm.eventhubs.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	EventHubSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	EventHubSpout.preparePartitions(Map config, int totalTasks, int taskIndex, SpoutOutputCollector collector) This is a extracted method that is easy to test

Uses of SpoutOutputCollector in org.apache.storm.hbase.topology

Methods in org.apache.storm.hbase.topology with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	WordSpout.open(Map 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 and Description
void	SequenceFileTopology.SentenceSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HdfsFileTopology.SentenceSpout.open(Map 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 and Description
SpoutOutputCollector	HdfsSpout.getCollector()

Methods in org.apache.storm.hdfs.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	HdfsSpout.open(Map 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 and Description
void	HiveTopologyPartitioned.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	HiveTopology.UserDataSpout.open(Map config, TopologyContext context, SpoutOutputCollector collector)
void	BucketTestHiveTopology.UserDataSpout.open(Map 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 and Description
void	UserSpout.open(Map 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 and Description
void	JmsSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector) ISpout implementation.

Uses of SpoutOutputCollector in org.apache.storm.kafka

Methods in org.apache.storm.kafka with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
org.apache.storm.kafka.KafkaSpout.EmitState	PartitionManager.next(SpoutOutputCollector collector)
void	KafkaSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector) Deprecated.

Uses of SpoutOutputCollector in org.apache.storm.kafka.spout

Fields in org.apache.storm.kafka.spout declared as SpoutOutputCollector

Modifier and Type	Field and Description
protected SpoutOutputCollector	KafkaSpout.collector

Methods in org.apache.storm.kafka.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	KafkaSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.kinesis.spout

Methods in org.apache.storm.kinesis.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	KinesisSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.mongodb.topology

Methods in org.apache.storm.mongodb.topology with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	WordSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.mqtt.spout

Fields in org.apache.storm.mqtt.spout declared as SpoutOutputCollector

Modifier and Type	Field and Description
protected SpoutOutputCollector	MqttSpout.collector

Methods in org.apache.storm.mqtt.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	MqttSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.opentsdb

Methods in org.apache.storm.opentsdb with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	MetricGenSpout.open(Map 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 and Description
void	StringGenSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FileReadSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	ConstSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.pmml

Methods in org.apache.storm.pmml with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	RawInputFromCSVSpout.open(Map 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 and Description
void	WordSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.solr.spout

Methods in org.apache.storm.solr.spout with parameters of type SpoutOutputCollector

Modifier and Type	Method and Description
void	SolrJsonSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	SolrFieldsSpout.open(Map 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 and Description
void	ShellSpout.open(Map stormConf, TopologyContext context, SpoutOutputCollector collector)
void	ISpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector) Called when a task for this component is initialized within a worker on the cluster.
void	CheckpointSpout.open(Map 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 and Description
void	ThroughputVsLatency.FastRandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	InOrderDeliveryTest.InOrderSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FastWordCountTopology.FastRandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	BlobStoreAPIWordCountTopology.RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	AnchoredWordCount.RandomSentenceSpout.open(Map 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 and Description
void	RandomSentenceSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	RandomIntegerSpout.open(Map 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 and Description
void	TestWordSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestPlannerSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	TestEventLogSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	SpoutTracker.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	PythonShellMetricsSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FixedTupleSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
void	FeederSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Uses of SpoutOutputCollector in org.apache.storm.transactional

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

Modifier and Type	Method and Description
void	TransactionalSpoutCoordinator.open(Map 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 and Description
void	RichSpoutBatchTriggerer.open(Map 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 and Description
void	MasterBatchCoordinator.open(Map conf, TopologyContext context, SpoutOutputCollector collector)