Package | Description |
---|---|
org.apache.flink.api.java.functions | |
org.apache.flink.hadoopcompatibility.mapred | |
org.apache.flink.table.runtime | |
org.apache.flink.table.runtime.aggregate |
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 | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
FlatMapRunner |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
DataSetSlideTimeWindowAggFlatMapFunction
It is used for sliding windows on batch for time-windows.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.