Uses of Class
org.apache.flink.cdc.common.pipeline.DecimalPrecisionMode

Packages that use DecimalPrecisionMode

Package	Description
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.async
org.apache.flink.cdc.runtime.parser

Uses of DecimalPrecisionMode in org.apache.flink.cdc.common.pipeline

Fields in org.apache.flink.cdc.common.pipeline with type parameters of type DecimalPrecisionMode

Modifier and Type	Field	Description
static ConfigOption<DecimalPrecisionMode>	PipelineOptions.PIPELINE_TRANSFORM_DECIMAL_PRECISION_MODE

Methods in org.apache.flink.cdc.common.pipeline that return DecimalPrecisionMode

Modifier and Type	Method	Description
static DecimalPrecisionMode	DecimalPrecisionMode.valueOf(String name)	Returns the enum constant of this type with the specified name.
static DecimalPrecisionMode[]	DecimalPrecisionMode.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Uses of DecimalPrecisionMode in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type DecimalPrecisionMode

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translateAsyncPostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, java.time.Duration asyncTransformTimeout, int asyncTransformCapacity, int asyncTransformWorkerThreads, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translatePostTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns, OperatorUidGenerator operatorUidGenerator, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Uses of DecimalPrecisionMode in org.apache.flink.cdc.runtime.operators.transform

Methods in org.apache.flink.cdc.runtime.operators.transform with parameters of type DecimalPrecisionMode

Modifier and Type	Method	Description
PostTransformOperatorBuilder	PostTransformOperatorBuilder.addDecimalPrecisionMode(DecimalPrecisionMode decimalPrecisionMode)
static TransformFilterProcessor	TransformFilterProcessor.of(PostTransformChangeInfo tableInfo, TransformFilter transformFilter, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)
static TransformFilterProcessor	TransformFilterProcessor.ofNoOp(DecimalPrecisionMode decimalPrecisionMode)

Constructors in org.apache.flink.cdc.runtime.operators.transform with parameters of type DecimalPrecisionMode

Constructor	Description
TransformFilterProcessor(boolean isNoOp, PostTransformChangeInfo tableInfo, TransformFilter transformFilter, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, Map<String,SupportedMetadataColumn> supportedMetadataColumns, Map<String,AiModelClient> modelClients)
TransformProjectionProcessor(PostTransformChangeInfo changeInfo, String projectionExpression, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)

Uses of DecimalPrecisionMode in org.apache.flink.cdc.runtime.operators.transform.async

Methods in org.apache.flink.cdc.runtime.operators.transform.async with parameters of type DecimalPrecisionMode

Modifier and Type	Method	Description
AsyncPostTransformFunctionBuilder	AsyncPostTransformFunctionBuilder.addDecimalPrecisionMode(DecimalPrecisionMode decimalPrecisionMode)

Uses of DecimalPrecisionMode in org.apache.flink.cdc.runtime.parser

Fields in org.apache.flink.cdc.runtime.parser declared as DecimalPrecisionMode

Modifier and Type	Field	Description
DecimalPrecisionMode	JaninoCompiler.Context.decimalPrecisionMode

Methods in org.apache.flink.cdc.runtime.parser with parameters of type DecimalPrecisionMode

Modifier and Type	Method	Description
static DataType	TransformParser.deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static List<ProjectionColumn>	TransformParser.generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static FlinkCdcTypeSystem	FlinkCdcTypeSystem.of(DecimalPrecisionMode mode)
static JaninoCompiler.Context	JaninoCompiler.Context.of(List<Column> columns, Map<String,String> columnNameMap, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static String	TransformParser.translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap, DecimalPrecisionMode decimalPrecisionMode)