blob: dc29fbbe7489f3a461d7871fb3fd37ab22e5f253 [file] [log] [blame]
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);
}