blob: 5e5b93caaba23276c49a5d44448cb0152e2fb132 [file] [log] [blame]
package backtype.storm.spout;
import java.util.List;
public interface ISpoutOutputCollector {
/**
Returns the task ids that received the tuples.
*/
List<Integer> emit(String streamId, List<Object> tuple, Object messageId);
void emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId);
}