public interface IBasicOutputCollector
Modifier and Type | Method and Description |
---|---|
List<Integer> |
emit(String streamId,
List<Object> tuple) |
void |
emitDirect(int taskId,
String streamId,
List<Object> tuple) |
void |
reportError(Throwable t) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.