backtype.storm.topology

Interface IBasicOutputCollector

All Known Implementing Classes:

BasicOutputCollector

public interface IBasicOutputCollector

Method Summary

Methods

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)

Method Detail

emit

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

emitDirect

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

reportError

void reportError(Throwable t)