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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidReturns the task ids that received the tuples.voidemitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple) voidvoidflush()voidreportError(Throwable error) voidresetTimeout(Tuple tuple)
-
Constructor Details
-
CoordinatedOutputCollector
-
-
Method Details
-
emit
Description copied from interface:IOutputCollectorReturns the task ids that received the tuples.- Specified by:
emitin interfaceIOutputCollector
-
emitDirect
- Specified by:
emitDirectin interfaceIOutputCollector
-
ack
- Specified by:
ackin interfaceIOutputCollector
-
fail
- Specified by:
failin interfaceIOutputCollector
-
flush
public void flush()- Specified by:
flushin interfaceIOutputCollector
-
resetTimeout
- Specified by:
resetTimeoutin interfaceIOutputCollector
-
reportError
- Specified by:
reportErrorin interfaceIErrorReporter
-