Package org.apache.storm.spout

Interface ISpoutOutputCollector

All Superinterfaces:

IErrorReporter

All Known Implementing Classes:

SpoutOutputCollector, SpoutOutputCollectorImpl

public interface ISpoutOutputCollector
extends IErrorReporter

Methods are not expected to be thread safe. Each thread expected to have a separate instance of this type of object, or else externally synchronize any shared instance.

Method Summary

Modifier and Type	Method	Description
List<Integer>	emit(String streamId, List<Object> tuple, Object messageId)	Returns the task ids that received the tuples.
void	emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId)
void	flush()
long	getPendingCount()

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

reportError

Method Details

emit

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

Returns the task ids that received the tuples.

emitDirect

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

getPendingCount

long getPendingCount()

flush

void flush()