Package | Description |
---|---|
org.apache.flink.streaming.api.functions.python | |
org.apache.flink.streaming.api.operators.python | |
org.apache.flink.streaming.api.utils |
Modifier and Type | Method and Description |
---|---|
DataStreamPythonFunctionInfo |
DataStreamPythonFunctionInfo.copy() |
Constructor and Description |
---|
DataStreamPythonFunctionInfo(PythonFunction pythonFunction,
DataStreamPythonFunctionInfo input,
int functionType) |
Modifier and Type | Method and Description |
---|---|
DataStreamPythonFunctionInfo |
AbstractDataStreamPythonFunctionOperator.getPythonFunctionInfo() |
Modifier and Type | Method and Description |
---|---|
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
abstract <T> AbstractDataStreamPythonFunctionOperator<T> |
AbstractDataStreamPythonFunctionOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.UserDefinedDataStreamFunction |
ProtoUtils.createUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static List<FlinkFnApi.UserDefinedDataStreamFunction> |
ProtoUtils.createUserDefinedDataStreamFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static List<FlinkFnApi.UserDefinedDataStreamFunction> |
ProtoUtils.createUserDefinedDataStreamStatefulFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation<?> keyTypeInfo,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.