package backtype.storm.spout; | |
import java.util.List; | |
import backtype.storm.tuple.Tuple; | |
public interface ISpoutOutputCollector { | |
/** | |
Returns the task ids that received the tuples. | |
*/ | |
List<Integer> emit(int streamId, List<Object> tuple, Object messageId); | |
void emitDirect(int taskId, int streamId, List<Object> tuple, Object messageId); | |
} | |