Uses of Class
backtype.storm.spout.SpoutOutputCollector

Packages that use SpoutOutputCollector

Package	Description
backtype.storm.clojure
backtype.storm.drpc
backtype.storm.spout
backtype.storm.testing
backtype.storm.transactional
storm.kafka
storm.starter.spout
storm.trident.spout
storm.trident.topology

Uses of SpoutOutputCollector in backtype.storm.clojure

Methods in backtype.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 backtype.storm.drpc

Methods in backtype.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 backtype.storm.spout

Methods in backtype.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.

Uses of SpoutOutputCollector in backtype.storm.testing

Methods in backtype.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 backtype.storm.transactional

Methods in backtype.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 storm.kafka

Methods in storm.kafka with parameters of type SpoutOutputCollector

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

Uses of SpoutOutputCollector in storm.starter.spout

Methods in storm.starter.spout with parameters of type SpoutOutputCollector

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

Uses of SpoutOutputCollector in storm.trident.spout

Methods in 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 storm.trident.topology

Methods in storm.trident.topology with parameters of type SpoutOutputCollector

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