Package | Description |
---|---|
org.apache.flink.streaming.python.api.functions |
Modifier and Type | Class and Description |
---|---|
class |
PythonApplyFunction<W extends Window>
The
PythonApplyFunction is a thin wrapper layer over a Python UDF WindowFunction . |
class |
PythonFilterFunction
The
PythonFilterFunction is a thin wrapper layer over a Python UDF FilterFunction . |
class |
PythonFlatMapFunction
The
PythonFlatMapFunction is a thin wrapper layer over a Python UDF FlatMapFunction . |
class |
PythonGeneratorFunction
The
PythonGeneratorFunction is a thin wrapper layer over a Python UDF SourceFunction . |
class |
PythonMapFunction
The
PythonMapFunction is a thin wrapper layer over a Python UDF MapFunction . |
class |
PythonSinkFunction
The
PythonSinkFunction is a thin wrapper layer over a Python UDF SinkFunction . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.