Package | Description |
---|---|
org.apache.flink.python.api.streaming.data |
Modifier and Type | Class and Description |
---|---|
class |
PythonStreamer<S extends PythonSender,OUT>
This streamer is used by functions to send/receive data to/from an external python process.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonDualInputSender<IN1,IN2>
This class is a
PythonSender for operations with two input streams. |
class |
PythonSingleInputSender<IN>
This class is a
PythonSender for operations with one input stream. |
Modifier and Type | Field and Description |
---|---|
protected S |
PythonStreamer.sender |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.