Uses of Class
org.apache.flink.streaming.api.functions.python.DataStreamPythonFunctionInfo

Packages that use DataStreamPythonFunctionInfo

Package	Description
org.apache.flink.python.util
org.apache.flink.streaming.api.functions.python
org.apache.flink.streaming.api.operators.python
org.apache.flink.streaming.api.operators.python.embedded
org.apache.flink.streaming.api.operators.python.process
org.apache.flink.streaming.api.transformations.python

Uses of DataStreamPythonFunctionInfo in org.apache.flink.python.util

Methods in org.apache.flink.python.util with parameters of type DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
static FlinkFnApi.UserDefinedDataStreamFunction	ProtoUtils.createUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
static List<FlinkFnApi.UserDefinedDataStreamFunction>	ProtoUtils.createUserDefinedDataStreamFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
static List<FlinkFnApi.UserDefinedDataStreamFunction>	ProtoUtils.createUserDefinedDataStreamStatefulFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, Map<String,String> internalParameters, org.apache.flink.api.common.typeinfo.TypeInformation<?> keyTypeInfo, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)

Uses of DataStreamPythonFunctionInfo in org.apache.flink.streaming.api.functions.python

Methods in org.apache.flink.streaming.api.functions.python that return DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
DataStreamPythonFunctionInfo	DataStreamPythonFunctionInfo.copy()

Constructors in org.apache.flink.streaming.api.functions.python with parameters of type DataStreamPythonFunctionInfo

Constructor	Description
DataStreamPythonFunctionInfo(org.apache.flink.table.functions.python.PythonFunction pythonFunction, DataStreamPythonFunctionInfo input, int functionType)

Uses of DataStreamPythonFunctionInfo in org.apache.flink.streaming.api.operators.python

Methods in org.apache.flink.streaming.api.operators.python that return DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
DataStreamPythonFunctionInfo	DataStreamPythonFunctionOperator.getPythonFunctionInfo()	Returns the underlying DataStreamPythonFunctionInfo.

Methods in org.apache.flink.streaming.api.operators.python with parameters of type DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
<T> DataStreamPythonFunctionOperator<T>	DataStreamPythonFunctionOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)	Make a copy of the DataStreamPythonFunctionOperator with the given pythonFunctionInfo and outputTypeInfo.

Uses of DataStreamPythonFunctionInfo in org.apache.flink.streaming.api.operators.python.embedded

Methods in org.apache.flink.streaming.api.operators.python.embedded that return DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
DataStreamPythonFunctionInfo	AbstractEmbeddedDataStreamPythonFunctionOperator.getPythonFunctionInfo()

Methods in org.apache.flink.streaming.api.operators.python.embedded with parameters of type DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractEmbeddedDataStreamPythonFunctionOperator<T>	EmbeddedPythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> DataStreamPythonFunctionOperator<T>	EmbeddedPythonWindowOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)

Constructors in org.apache.flink.streaming.api.operators.python.embedded with parameters of type DataStreamPythonFunctionInfo

Constructor	Description
AbstractEmbeddedDataStreamPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
AbstractOneInputEmbeddedPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
AbstractTwoInputEmbeddedPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonBatchCoBroadcastProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonBatchKeyedCoBroadcastProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonCoProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonKeyedCoProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonKeyedProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
EmbeddedPythonWindowOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer)

Uses of DataStreamPythonFunctionInfo in org.apache.flink.streaming.api.operators.python.process

Methods in org.apache.flink.streaming.api.operators.python.process that return DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
DataStreamPythonFunctionInfo	AbstractExternalDataStreamPythonFunctionOperator.getPythonFunctionInfo()

Methods in org.apache.flink.streaming.api.operators.python.process with parameters of type DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
<T> AbstractExternalDataStreamPythonFunctionOperator<T>	ExternalPythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractExternalDataStreamPythonFunctionOperator<T>	ExternalPythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractExternalDataStreamPythonFunctionOperator<T>	ExternalPythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
<T> AbstractExternalDataStreamPythonFunctionOperator<T>	ExternalPythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)

Constructors in org.apache.flink.streaming.api.operators.python.process with parameters of type DataStreamPythonFunctionInfo

Constructor	Description
AbstractExternalDataStreamPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
AbstractExternalOneInputPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
AbstractExternalTwoInputPythonFunctionOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonBatchCoBroadcastProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonBatchKeyedCoBroadcastProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonCoProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonKeyedCoProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> inputTypeInfo1, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> inputTypeInfo2, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonKeyedProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.java.typeutils.RowTypeInfo inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)
ExternalPythonKeyedProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.java.typeutils.RowTypeInfo inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo, org.apache.flink.api.common.typeutils.TypeSerializer namespaceSerializer)
ExternalPythonProcessOperator(org.apache.flink.configuration.Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN> inputTypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputTypeInfo)

Uses of DataStreamPythonFunctionInfo in org.apache.flink.streaming.api.transformations.python

Methods in org.apache.flink.streaming.api.transformations.python that return DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
DataStreamPythonFunctionInfo	PythonBroadcastStateTransformation.getDataStreamPythonFunctionInfo()
DataStreamPythonFunctionInfo	PythonKeyedBroadcastStateTransformation.getDataStreamPythonFunctionInfo()
DataStreamPythonFunctionInfo	DelegateOperatorTransformation.DelegateOperator.getPythonFunctionInfo()

Methods in org.apache.flink.streaming.api.transformations.python with parameters of type DataStreamPythonFunctionInfo

Modifier and Type	Method	Description
<T> DataStreamPythonFunctionOperator<T>	DelegateOperatorTransformation.DelegateOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo, org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)

Constructors in org.apache.flink.streaming.api.transformations.python with parameters of type DataStreamPythonFunctionInfo

Constructor	Description
PythonBroadcastStateTransformation(String name, org.apache.flink.configuration.Configuration configuration, DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, org.apache.flink.api.dag.Transformation<IN1> regularInput, org.apache.flink.api.dag.Transformation<IN2> broadcastInput, List<org.apache.flink.api.common.state.MapStateDescriptor<?,?>> broadcastStateDescriptors, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, int parallelism)
PythonKeyedBroadcastStateTransformation(String name, org.apache.flink.configuration.Configuration configuration, DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, org.apache.flink.api.dag.Transformation<org.apache.flink.types.Row> regularInput, org.apache.flink.api.dag.Transformation<org.apache.flink.types.Row> broadcastInput, List<org.apache.flink.api.common.state.MapStateDescriptor<?,?>> broadcastStateDescriptors, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> keyType, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.types.Row,org.apache.flink.types.Row> keySelector, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, int parallelism)