Package | Description |
---|---|
org.apache.flink.api.java.functions | |
org.apache.flink.hadoopcompatibility.mapred | |
org.apache.flink.table.plan.nodes | |
org.apache.flink.table.runtime |
Modifier and Type | Class and Description |
---|---|
class |
FlatMapIterator<IN,OUT>
A convenience variant of the
RichFlatMapFunction that returns elements through an iterator, rather then
through a collector. |
Modifier and Type | Class and Description |
---|---|
class |
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
Modifier and Type | Method and Description |
---|---|
RichFlatMapFunction<Object,Object> |
FlinkCalc.calcMapFunction(GeneratedFunction<FlatMapFunction<Object,Object>> genFunction) |
Modifier and Type | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
FlatMapRunner<IN,OUT> |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.