Uses of Interface
org.apache.flink.cdc.common.source.SupportedMetadataColumn

Packages that use SupportedMetadataColumn

Package	Description
org.apache.flink.cdc.common.source
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.values.source
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.async
org.apache.flink.cdc.runtime.parser

Uses of SupportedMetadataColumn in org.apache.flink.cdc.common.source

Methods in org.apache.flink.cdc.common.source that return SupportedMetadataColumn

Modifier and Type	Method	Description
default SupportedMetadataColumn[]	DataSource.supportedMetadataColumns()	Get the SupportedMetadataColumns of the source.

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

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

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)
org.apache.flink.streaming.api.datastream.DataStream<Event>	TransformTranslator.translatePreTransform(org.apache.flink.streaming.api.datastream.DataStream<Event> input, List<TransformDef> transforms, List<UdfDef> udfFunctions, List<ModelDef> models, SupportedMetadataColumn[] supportedMetadataColumns)

Uses of SupportedMetadataColumn in org.apache.flink.cdc.connectors.mysql.source

Classes in org.apache.flink.cdc.connectors.mysql.source that implement SupportedMetadataColumn

Modifier and Type	Class	Description
class	OpTsMetadataColumn	A SupportedMetadataColumn for op_ts.

Methods in org.apache.flink.cdc.connectors.mysql.source that return SupportedMetadataColumn

Modifier and Type	Method	Description
SupportedMetadataColumn[]	MySqlDataSource.supportedMetadataColumns()

Uses of SupportedMetadataColumn in org.apache.flink.cdc.connectors.postgres.source

Classes in org.apache.flink.cdc.connectors.postgres.source that implement SupportedMetadataColumn

Modifier and Type	Class	Description
class	DatabaseNameMetadataColumn	A SupportedMetadataColumn for database_name.
class	OpTsMetadataColumn	A SupportedMetadataColumn for op_ts.
class	SchemaNameMetadataColumn	A SupportedMetadataColumn for schema_name.
class	TableNameMetadataColumn	A SupportedMetadataColumn for table_name.

Methods in org.apache.flink.cdc.connectors.postgres.source that return SupportedMetadataColumn

Modifier and Type	Method	Description
SupportedMetadataColumn[]	PostgresDataSource.supportedMetadataColumns()

Uses of SupportedMetadataColumn in org.apache.flink.cdc.connectors.values.source

Classes in org.apache.flink.cdc.connectors.values.source that implement SupportedMetadataColumn

Modifier and Type	Class	Description
class	OpTsMetadataColumn	A SupportedMetadataColumn for op_ts.
class	TimestampTypeMetadataColumn	A SupportedMetadataColumn for timestamp-type.

Methods in org.apache.flink.cdc.connectors.values.source that return SupportedMetadataColumn

Modifier and Type	Method	Description
SupportedMetadataColumn[]	ValuesDataSource.supportedMetadataColumns()

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

Methods in org.apache.flink.cdc.runtime.operators.transform that return SupportedMetadataColumn

Modifier and Type	Method	Description
SupportedMetadataColumn[]	PostTransformer.getSupportedMetadataColumns()
SupportedMetadataColumn[]	TransformRule.getSupportedMetadataColumns()

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

Modifier and Type	Method	Description
PostTransformOperatorBuilder	PostTransformOperatorBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOptions, String tableOptionsDelimiter, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
PostTransformOperatorBuilder	PostTransformOperatorBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOptions, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
PreTransformOperatorBuilder	PreTransformOperatorBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOption, String tableOptionsDelimiter, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
PreTransformOperatorBuilder	PreTransformOperatorBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOption, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
static TransformFilterProcessor	TransformFilterProcessor.of(PostTransformChangeInfo tableInfo, TransformFilter transformFilter, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)

Method parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type SupportedMetadataColumn

Modifier and Type	Method	Description
static Object	TransformContext.lookupObjectByName(String name, PostTransformChangeInfo tableInfo, Map<String,SupportedMetadataColumn> supportedMetadataColumns, Object[] preRow, Object[] postRow, TransformContext context)	Retrieve a corresponding object based on identifier name.
static ProjectionColumnProcessor	ProjectionColumnProcessor.of(PostTransformChangeInfo tableInfo, ProjectionColumn projectionColumn, String timezone, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, Map<String,SupportedMetadataColumn> supportedMetadataColumns)
static ProjectionColumnProcessor	ProjectionColumnProcessor.of(PostTransformChangeInfo tableInfo, ProjectionColumn projectionColumn, String timezone, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, Map<String,SupportedMetadataColumn> supportedMetadataColumns, Map<String,AiModelClient> modelClients)

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

Constructor	Description
PostTransformer(Selectors selectors, TransformProjection projection, TransformFilter filter, PostTransformConverter postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
TransformProjectionProcessor(PostTransformChangeInfo changeInfo, String projectionExpression, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)
TransformRule(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOption, String tableOptionsDelimiter, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)

Constructor parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type SupportedMetadataColumn

Constructor	Description
ProjectionColumnProcessor(PostTransformChangeInfo tableInfo, ProjectionColumn projectionColumn, String timezone, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, Map<String,SupportedMetadataColumn> supportedMetadataColumns, Map<String,AiModelClient> modelClients)
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)

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

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

Modifier and Type	Method	Description
AsyncPostTransformFunctionBuilder	AsyncPostTransformFunctionBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOptions, String tableOptionsDelimiter, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)
AsyncPostTransformFunctionBuilder	AsyncPostTransformFunctionBuilder.addTransform(String tableInclusions, String projection, String filter, String primaryKey, String partitionKey, String tableOptions, String postTransformConverter, SupportedMetadataColumn[] supportedMetadataColumns)

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

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

Modifier and Type	Field	Description
SupportedMetadataColumn[]	JaninoCompiler.Context.supportedMetadataColumns

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

Modifier and Type	Method	Description
static DataType	TransformParser.deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
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)
static List<ProjectionColumn>	TransformParser.generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static JaninoCompiler.Context	JaninoCompiler.Context.of(List<Column> columns, Map<String,String> columnNameMap, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static JaninoCompiler.Context	JaninoCompiler.Context.of(List<Column> columns, Map<String,String> columnNameMap, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static List<String>	TransformParser.parseComputedColumnNames(String projection, SupportedMetadataColumn[] supportedMetadataColumns)
static ProjectionColumn	TransformParser.resolveProjectionColumnFromIdentifier(org.apache.calcite.rel.type.RelDataType relDataType, Map<String,Column> originalColumnMap, String identifier, String projectedColumnName, SupportedMetadataColumn[] supportedMetadataColumns)	Create a projection column from a simple identifier node (could be an upstream physical column or a metadata column).
static String	TransformParser.translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap)
static String	TransformParser.translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap, DecimalPrecisionMode decimalPrecisionMode)