O
I
public interface FlatMapFunc<O,I> extends TFunction<O,I>
void
flatMap(I input, RecordCollector<O> collector)
close, end, prepare
void flatMap(I input, RecordCollector<O> collector)