public interface IBasicOutputCollector
Modifier and Type | Method and Description |
---|---|
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 |
reportError(java.lang.Throwable t) |