BasicOutputCollector (Storm 2.1.0 API)

public class BasicOutputCollector
extends Object
implements IBasicOutputCollector

Constructors
Constructor and Description
`BasicOutputCollector(OutputCollector out)`

All Methods Instance Methods Concrete Methods
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)

public List<Integer> emit(List<Object> tuple)

public void setContext(Tuple inputTuple)

public void emitDirect(int taskId,
                       String streamId,
                       List<Object> tuple)

public void emitDirect(int taskId,
                       List<Object> tuple)

protected IOutputCollector getOutputter()

Class BasicOutputCollector