public class BasicOutputCollector extends Object implements IBasicOutputCollector
| Constructor and Description |
|---|
BasicOutputCollector(OutputCollector out) |
| Modifier and Type | Method and Description |
|---|---|
List<Integer> |
emit(List<Object> tuple) |
List<Integer> |
emit(String streamId,
List<Object> tuple) |
void |
emitDirect(int taskId,
List<Object> tuple) |
void |
emitDirect(int taskId,
String streamId,
List<Object> tuple) |
protected IOutputCollector |
getOutputter() |
void |
reportError(Throwable t) |
void |
setContext(Tuple inputTuple) |
public BasicOutputCollector(OutputCollector out)
public List<Integer> emit(String streamId, List<Object> tuple)
emit in interface IBasicOutputCollectorpublic void setContext(Tuple inputTuple)
public void emitDirect(int taskId,
String streamId,
List<Object> tuple)
emitDirect in interface IBasicOutputCollectorprotected IOutputCollector getOutputter()
public void reportError(Throwable t)
reportError in interface IBasicOutputCollectorCopyright © 2015. All rights reserved.