backtype.storm.coordination
Class BatchOutputCollectorImpl
java.lang.Object
backtype.storm.coordination.BatchOutputCollector
backtype.storm.coordination.BatchOutputCollectorImpl
public class BatchOutputCollectorImpl
- extends BatchOutputCollector
Method Summary |
void |
ack(Tuple tup)
|
java.util.List<java.lang.Integer> |
emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
|
void |
emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
|
void |
fail(Tuple tup)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BatchOutputCollectorImpl
public BatchOutputCollectorImpl(OutputCollector collector)
emit
public java.util.List<java.lang.Integer> emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
- Specified by:
emit
in class BatchOutputCollector
emitDirect
public void emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
- Specified by:
emitDirect
in class BatchOutputCollector
ack
public void ack(Tuple tup)
fail
public void fail(Tuple tup)