Package org.apache.storm.coordination
Class CoordinatedBolt.CoordinatedOutputCollector
- java.lang.Object
-
- org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
-
- All Implemented Interfaces:
IErrorReporter,IOutputCollector
- Enclosing class:
- CoordinatedBolt
public class CoordinatedBolt.CoordinatedOutputCollector extends Object implements IOutputCollector
-
-
Constructor Summary
Constructors Constructor Description CoordinatedOutputCollector(IOutputCollector delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidack(Tuple tuple)List<Integer>emit(String stream, Collection<Tuple> anchors, List<Object> tuple)Returns the task ids that received the tuples.voidemitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)voidfail(Tuple tuple)voidflush()voidreportError(Throwable error)voidresetTimeout(Tuple tuple)
-
-
-
Constructor Detail
-
CoordinatedOutputCollector
public CoordinatedOutputCollector(IOutputCollector delegate)
-
-
Method Detail
-
emit
public List<Integer> emit(String stream, Collection<Tuple> anchors, List<Object> tuple)
Description copied from interface:IOutputCollectorReturns the task ids that received the tuples.- Specified by:
emitin interfaceIOutputCollector
-
emitDirect
public void emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)- Specified by:
emitDirectin interfaceIOutputCollector
-
ack
public void ack(Tuple tuple)
- Specified by:
ackin interfaceIOutputCollector
-
fail
public void fail(Tuple tuple)
- Specified by:
failin interfaceIOutputCollector
-
flush
public void flush()
- Specified by:
flushin interfaceIOutputCollector
-
resetTimeout
public void resetTimeout(Tuple tuple)
- Specified by:
resetTimeoutin interfaceIOutputCollector
-
reportError
public void reportError(Throwable error)
- Specified by:
reportErrorin interfaceIErrorReporter
-
-