blob: c39696463a75c5126a036ba0b1c7f1a178c82e76 [file] [log] [blame]
package backtype.storm.topology;
import java.util.List;
public interface IBasicOutputCollector {
List<Integer> emit(String streamId, List<Object> tuple);
void emitDirect(int taskId, String streamId, List<Object> tuple);
void reportError(Throwable t);
}