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

Packages that use SpoutOutputCollector

Package	Description
org.apache.storm
org.apache.storm.clojure
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
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.spout
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.perf.spout
org.apache.storm.redis.topology
org.apache.storm.spout
org.apache.storm.sql.runtime.datasource.socket.spout
org.apache.storm.st.topology.window
org.apache.storm.starter
org.apache.storm.starter.spout
org.apache.storm.testing
org.apache.storm.trident.spout
org.apache.storm.trident.topology

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.elasticsearch.bolt

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

Modifier and Type	Method	Description
void	EsIndexTopology.UserDataSpout.open(Map<String,Object> config, TopologyContext context, SpoutOutputCollector collectorArg)	Acquires collector and initializes pending.

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)