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