public interface IBasicOutputCollector
List<Integer>
emit(String streamId, List<Object> tuple)
void
emitDirect(int taskId, String streamId, List<Object> tuple)
reportError(Throwable t)
List<Integer> emit(String streamId, List<Object> tuple)
void emitDirect(int taskId, String streamId, List<Object> tuple)
void reportError(Throwable t)
Copyright © 2015. All rights reserved.