Package org.apache.storm.topology

Interface IBasicOutputCollector

All Superinterfaces:

IErrorReporter

All Known Implementing Classes:

BasicOutputCollector

public interface IBasicOutputCollector
extends IErrorReporter

Method Summary

Modifier and Type	Method	Description
List<Integer>	emit(String streamId, List<Object> tuple)
void	emitDirect(int taskId, String streamId, List<Object> tuple)
void	resetTimeout(Tuple tuple)

Methods inherited from interface org.apache.storm.task.IErrorReporter

reportError

Method Detail

emit

List<Integer> emit(String streamId,
                   List<Object> tuple)

emitDirect

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

resetTimeout

void resetTimeout(Tuple tuple)