public static class FlatMapFunctions.FlatMapFuncImpl extends java.lang.Object implements FlatMapFunc, java.io.Serializable
Modifier and Type | Method and Description |
---|---|
void |
flatMap(java.lang.Object o,
RecordCollector collector) |
public void flatMap(java.lang.Object o, RecordCollector collector)
flatMap
in interface FlatMapFunc