Java部分核心接口

Function层

PythonFunction接口

�里面存储python代码的序列化

PythonFunctionInfo

DataStreamPythonFunctionInfo
��
在上类基础上额外加一个functionType类型

PythonFunctionRunner

�

Operator层

AbstractPythonFunctionOperator

AbstractExternalPythonFunctionOperator 外部式运行，进程模型
AbstractDataStreamPythonFunctionOperator
��进程模型是借助Apache Beam的代码实现JVM和Python VM进程间通信
�AbstractEmbeddedPythonFunctionOperator 嵌入式运行，线程模型
�

会把Python算子先用Cloudpickle序列化

\后再用protobuf序列化。
�