@Internal public enum ProtoUtils extends Enum<ProtoUtils>
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
createArrowTypeCoderInfoDescriptorProto(RowType rowType,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage) |
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder |
createCoderProto(FlinkFnApi.CoderInfoDescriptor coderInfoDescriptor) |
static FlinkFnApi.CoderInfoDescriptor |
createFlattenRowTypeCoderInfoDescriptorProto(RowType rowType,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage) |
static FlinkFnApi.CoderInfoDescriptor |
createOverWindowArrowTypeCoderInfoDescriptorProto(RowType rowType,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage) |
static FlinkFnApi.CoderInfoDescriptor |
createRawTypeCoderInfoDescriptorProto(TypeInformation<?> typeInformation,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage,
ClassLoader userCodeClassLoader) |
static FlinkFnApi.UserDefinedDataStreamFunction |
createReviseOutputDataStreamFunctionProto() |
static FlinkFnApi.CoderInfoDescriptor |
createRowTypeCoderInfoDescriptorProto(RowType rowType,
FlinkFnApi.CoderInfoDescriptor.Mode mode,
boolean separatedWithEndMessage) |
static FlinkFnApi.UserDefinedAggregateFunction |
createUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo,
DataViewSpec[] dataViewSpecs) |
static FlinkFnApi.UserDefinedDataStreamFunction |
createUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
boolean hasSideOutput,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static List<FlinkFnApi.UserDefinedDataStreamFunction> |
createUserDefinedDataStreamFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
boolean hasSideOutput,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static List<FlinkFnApi.UserDefinedDataStreamFunction> |
createUserDefinedDataStreamStatefulFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo,
RuntimeContext runtimeContext,
Map<String,String> internalParameters,
TypeInformation<?> keyTypeInfo,
boolean inBatchExecutionMode,
boolean isMetricEnabled,
boolean isProfileEnabled,
boolean hasSideOutput,
int stateCacheSize,
int mapStateReadCacheSize,
int mapStateWriteCacheSize) |
static FlinkFnApi.UserDefinedFunction |
createUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo) |
static FlinkFnApi.UserDefinedFunctions |
createUserDefinedFunctionsProto(RuntimeContext runtimeContext,
PythonFunctionInfo[] userDefinedFunctions,
boolean isMetricEnabled,
boolean isProfileEnabled) |
static StateTtlConfig |
parseStateTtlConfigFromProto(FlinkFnApi.StateDescriptor.StateTTLConfig stateTTLConfigProto) |
static ProtoUtils |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ProtoUtils[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static ProtoUtils[] values()
for (ProtoUtils c : ProtoUtils.values()) System.out.println(c);
public static ProtoUtils valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic static org.apache.beam.model.pipeline.v1.RunnerApi.Coder createCoderProto(FlinkFnApi.CoderInfoDescriptor coderInfoDescriptor)
public static FlinkFnApi.CoderInfoDescriptor createRowTypeCoderInfoDescriptorProto(RowType rowType, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static FlinkFnApi.CoderInfoDescriptor createFlattenRowTypeCoderInfoDescriptorProto(RowType rowType, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static FlinkFnApi.CoderInfoDescriptor createArrowTypeCoderInfoDescriptorProto(RowType rowType, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static FlinkFnApi.CoderInfoDescriptor createOverWindowArrowTypeCoderInfoDescriptorProto(RowType rowType, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static FlinkFnApi.UserDefinedFunctions createUserDefinedFunctionsProto(RuntimeContext runtimeContext, PythonFunctionInfo[] userDefinedFunctions, boolean isMetricEnabled, boolean isProfileEnabled)
public static FlinkFnApi.UserDefinedFunction createUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)
public static FlinkFnApi.UserDefinedAggregateFunction createUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo, DataViewSpec[] dataViewSpecs)
public static FlinkFnApi.UserDefinedDataStreamFunction createUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
public static FlinkFnApi.UserDefinedDataStreamFunction createReviseOutputDataStreamFunctionProto()
public static List<FlinkFnApi.UserDefinedDataStreamFunction> createUserDefinedDataStreamFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
public static List<FlinkFnApi.UserDefinedDataStreamFunction> createUserDefinedDataStreamStatefulFunctionProtos(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, TypeInformation<?> keyTypeInfo, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, boolean hasSideOutput, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
public static FlinkFnApi.CoderInfoDescriptor createRawTypeCoderInfoDescriptorProto(TypeInformation<?> typeInformation, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage, ClassLoader userCodeClassLoader)
public static StateTtlConfig parseStateTtlConfigFromProto(FlinkFnApi.StateDescriptor.StateTTLConfig stateTTLConfigProto)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.