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 |
resetTimeout(Tuple tuple)
Resets the message timeout for any tuple trees to which the given tuple belongs.
|
void |
setContext(Tuple inputTuple) |
public BasicOutputCollector(OutputCollector out)
public List<Integer> emit(String streamId, List<Object> tuple)
emit
in interface IBasicOutputCollector
public void setContext(Tuple inputTuple)
public void emitDirect(int taskId, String streamId, List<Object> tuple)
emitDirect
in interface IBasicOutputCollector
public void resetTimeout(Tuple tuple)
Resets the message timeout for any tuple trees to which the given tuple belongs. The timeout is reset to Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS. Note that this is an expensive operation, and should be used sparingly.
resetTimeout
in interface IBasicOutputCollector
tuple
- the tuple to reset timeout forprotected IOutputCollector getOutputter()
public void reportError(Throwable t)
reportError
in interface IErrorReporter
Copyright © 2022 The Apache Software Foundation. All rights reserved.