|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object backtype.storm.testing.FixedTupleSpout
public class FixedTupleSpout
Constructor Summary | |
---|---|
FixedTupleSpout(java.util.List tuples)
|
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 |
cleanup()
|
static void |
clear(java.lang.String stormId)
|
void |
close()
Called when an ISpout is going to be shutdown. |
void |
fail(java.lang.Object msgId)
The tuple emitted by this spout with the msgId identifier has failed to be fully processed. |
int |
getCompleted()
|
static int |
getNumAcked(java.lang.String stormId)
|
static int |
getNumFailed(java.lang.String stormId)
|
java.util.List<FixedTuple> |
getSourceTuples()
|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FixedTupleSpout(java.util.List tuples)
Method Detail |
---|
public static int getNumAcked(java.lang.String stormId)
public static int getNumFailed(java.lang.String stormId)
public static void clear(java.lang.String stormId)
public java.util.List<FixedTuple> getSourceTuples()
public int getCompleted()
public void cleanup()
public void open(java.util.Map conf, TopologyContext context, SpoutOutputCollector collector)
ISpout
This includes the:
open
in interface ISpout
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
public void nextTuple()
ISpout
nextTuple
in interface ISpout
public void ack(java.lang.Object msgId)
ISpout
ack
in interface ISpout
public void fail(java.lang.Object msgId)
ISpout
fail
in interface ISpout
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |