|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object backtype.storm.topology.base.BaseComponent backtype.storm.topology.base.BaseRichSpout backtype.storm.testing.FeederSpout
public class FeederSpout
Constructor Summary | |
---|---|
FeederSpout(Fields outFields)
|
Method Summary | |
---|---|
void |
ack(java.lang.Object msgId)
Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed. |
void |
close()
Called when an ISpout is going to be shutdown. |
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology. |
void |
fail(java.lang.Object msgId)
The tuple emitted by this spout with the msgId identifier has failed to be fully processed. |
void |
feed(java.util.List<java.lang.Object> tuple)
|
void |
feed(java.util.List<java.lang.Object> tuple,
java.lang.Object msgId)
|
java.util.Map<java.lang.String,java.lang.Object> |
getComponentConfiguration()
Declare configuration specific to this component. |
void |
nextTuple()
When this method is called, Storm is requesting that the Spout emit tuples to the output collector. |
void |
open(java.util.Map conf,
TopologyContext context,
SpoutOutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster. |
void |
setAckFailDelegate(AckFailDelegate d)
|
Methods inherited from class backtype.storm.topology.base.BaseRichSpout |
---|
activate, deactivate |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FeederSpout(Fields outFields)
Method Detail |
---|
public void setAckFailDelegate(AckFailDelegate d)
public void feed(java.util.List<java.lang.Object> tuple)
public void feed(java.util.List<java.lang.Object> tuple, java.lang.Object msgId)
public void open(java.util.Map conf, TopologyContext context, SpoutOutputCollector collector)
ISpout
This includes the:
conf
- The Storm configuration for this spout. This is the configuration provided to the topology merged in with cluster configuration on this machine.context
- This object can be used to get information about this task's place within the topology, including the task id and component id of this task, input and output information, etc.collector
- The collector is used to emit tuples from this spout. Tuples can be emitted at any time, including the open and close methods. The collector is thread-safe and should be saved as an instance variable of this spout object.public void close()
ISpout
The one context where close is guaranteed to be called is a topology is killed when running Storm in local mode.
close
in interface ISpout
close
in class BaseRichSpout
public void nextTuple()
ISpout
public void ack(java.lang.Object msgId)
ISpout
ack
in interface ISpout
ack
in class BaseRichSpout
public void fail(java.lang.Object msgId)
ISpout
fail
in interface ISpout
fail
in class BaseRichSpout
public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponent
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streampublic java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
IComponent
TopologyBuilder
getComponentConfiguration
in interface IComponent
getComponentConfiguration
in class BaseComponent
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |