backtype.storm.coordination
Class CoordinatedBolt.CoordinatedOutputCollector
java.lang.Object
backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
- All Implemented Interfaces:
- IOutputCollector
- Enclosing class:
- CoordinatedBolt
public class CoordinatedBolt.CoordinatedOutputCollector
- extends java.lang.Object
- implements IOutputCollector
Method Summary |
void |
ack(Tuple tuple)
|
java.util.List<java.lang.Integer> |
emit(java.lang.String stream,
java.util.Collection<Tuple> anchors,
java.util.List<java.lang.Object> tuple)
Returns the task ids that received the tuples. |
void |
emitDirect(int task,
java.lang.String stream,
java.util.Collection<Tuple> anchors,
java.util.List<java.lang.Object> tuple)
|
void |
fail(Tuple tuple)
|
void |
reportError(java.lang.Throwable error)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CoordinatedBolt.CoordinatedOutputCollector
public CoordinatedBolt.CoordinatedOutputCollector(IOutputCollector delegate)
emit
public java.util.List<java.lang.Integer> emit(java.lang.String stream,
java.util.Collection<Tuple> anchors,
java.util.List<java.lang.Object> tuple)
- Description copied from interface:
IOutputCollector
- Returns the task ids that received the tuples.
- Specified by:
emit
in interface IOutputCollector
emitDirect
public void emitDirect(int task,
java.lang.String stream,
java.util.Collection<Tuple> anchors,
java.util.List<java.lang.Object> tuple)
- Specified by:
emitDirect
in interface IOutputCollector
ack
public void ack(Tuple tuple)
- Specified by:
ack
in interface IOutputCollector
fail
public void fail(Tuple tuple)
- Specified by:
fail
in interface IOutputCollector
reportError
public void reportError(java.lang.Throwable error)
- Specified by:
reportError
in interface IOutputCollector