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 |
SemanticsCheckMapper
This mapper validates exactly-once and at-least-once semantics in connection with
SequenceGeneratorSource . |
class |
SlidingWindowCheckMapper
This mapper validates sliding event time window.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonScalarFunctionFlatMap
The abstract base
RichFlatMapFunction used to invoke Python ScalarFunction
functions for the old planner. |
class |
AbstractPythonStatelessFunctionFlatMap
Base Python stateless
RichFlatMapFunction used to invoke Python stateless functions for
the old planner. |
class |
PythonScalarFunctionFlatMap
The
RichFlatMapFunction used to invoke Python ScalarFunction functions for the
old planner. |
class |
PythonTableFunctionFlatMap
The
RichFlatMapFunction used to invoke Python TableFunction functions for the old
planner. |
Modifier and Type | Class and Description |
---|---|
class |
ArrowPythonScalarFunctionFlatMap
The
RichFlatMapFunction used to invoke Arrow Python ScalarFunction functions for
the old planner. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.