Package org.apache.flink.cdc.connectors.fluss.utils

Class FlussConversions

java.lang.Object

org.apache.flink.cdc.connectors.fluss.utils.FlussConversions

public class FlussConversions
extends Object

Converter between Flink CDC types and Fluss types.

Constructor Summary

Constructors

Constructor	Description
FlussConversions()

Method Summary

Modifier and Type	Method	Description
static Boolean	sameSchemaIgnoreCommentAndDefaultValue(Schema oldSchema, Schema newSchema)
static Schema	toCdcSchema(org.apache.fluss.metadata.Schema flussSchema)	Converts a Fluss schema to a Flink CDC schema.
static Schema	toCdcSchema(org.apache.fluss.metadata.Schema flussSchema, List<String> partitionKeys)	Converts a Fluss schema to a Flink CDC schema with table partition keys.
static DataType	toCdcType(org.apache.fluss.types.DataType flussType)	Converts a Fluss data type to a Flink CDC data type.
static org.apache.fluss.metadata.Schema	toFlussSchema(Schema cdcSchema)
static org.apache.fluss.metadata.TableDescriptor	toFlussTable(Schema cdcSchema, List<String> bucketKeys, Integer bucketNum, Map<String,String> tableProperties)
static org.apache.fluss.types.DataType	toFlussType(DataType flinkDataType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlussConversions

public FlussConversions()

Method Detail

toCdcSchema

public static Schema toCdcSchema(org.apache.fluss.metadata.Schema flussSchema)

Converts a Fluss schema to a Flink CDC schema.

toCdcSchema

public static Schema toCdcSchema(org.apache.fluss.metadata.Schema flussSchema,
                                 List<String> partitionKeys)

Converts a Fluss schema to a Flink CDC schema with table partition keys.

toCdcType

public static DataType toCdcType(org.apache.fluss.types.DataType flussType)

Converts a Fluss data type to a Flink CDC data type.

toFlussTable

public static org.apache.fluss.metadata.TableDescriptor toFlussTable(Schema cdcSchema,
                                                                     List<String> bucketKeys,
                                                                     @Nullable
                                                                     Integer bucketNum,
                                                                     Map<String,String> tableProperties)

toFlussSchema

public static org.apache.fluss.metadata.Schema toFlussSchema(Schema cdcSchema)

toFlussType

public static org.apache.fluss.types.DataType toFlussType(DataType flinkDataType)

sameSchemaIgnoreCommentAndDefaultValue

public static Boolean sameSchemaIgnoreCommentAndDefaultValue(Schema oldSchema,
                                                             Schema newSchema)