@Internal public enum ProtoUtils extends Enum<ProtoUtils>
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 FlinkFnApi.UserDefinedFunction getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)
public static FlinkFnApi.UserDefinedAggregateFunction getUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo, DataViewSpec[] dataViewSpecs)
public static FlinkFnApi.UserDefinedDataStreamFunction createUserDefinedDataStreamFunctionProto(DataStreamPythonFunctionInfo dataStreamPythonFunctionInfo, RuntimeContext runtimeContext, Map<String,String> internalParameters, boolean inBatchExecutionMode, boolean isMetricEnabled, boolean isProfileEnabled, 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, 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, int stateCacheSize, int mapStateReadCacheSize, int mapStateWriteCacheSize)
public static org.apache.beam.model.pipeline.v1.RunnerApi.Coder createCoderProto(FlinkFnApi.CoderInfoDescriptor coderInfoDescriptor)
public static FlinkFnApi.CoderInfoDescriptor createFlattenRowTypeCoderInfoDescriptorProto(RowType rowType, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static FlinkFnApi.CoderInfoDescriptor createRowTypeCoderInfoDescriptorProto(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.CoderInfoDescriptor createRawTypeCoderInfoDescriptorProto(TypeInformation<?> typeInformation, FlinkFnApi.CoderInfoDescriptor.Mode mode, boolean separatedWithEndMessage)
public static StateTtlConfig parseStateTtlConfigFromProto(FlinkFnApi.StateDescriptor.StateTTLConfig stateTTLConfigProto)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.