Package org.apache.flink.cdc.connectors.starrocks.sink

Class StarRocksUtils

java.lang.Object

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksUtils

public class StarRocksUtils
extends Object

Utilities for conversion from source table to StarRocks table.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StarRocksUtils.CdcDataTypeTransformer	Transforms CDC DataType to StarRocks data type.

Field Summary

Fields

Modifier and Type	Field	Description
static String	BIGINT
static String	BOOLEAN
static String	CHAR
static String	DATE
static String	DATETIME
static String	DECIMAL
static String	DEFAULT_DATETIME
static String	DOUBLE
static String	FLOAT
static String	INT
static String	INVALID_OR_MISSING_DATATIME
static String	JSON
static String	LARGEINT
static int	MAX_CHAR_SIZE	Max size of char type of StarRocks.
static int	MAX_VARBINARY_SIZE	Max size of varbinary type of StarRocks.
static int	MAX_VARCHAR_SIZE	Max size of varchar type of StarRocks.
static String	SMALLINT
static String	STRING
static String	TINYINT
static String	VARBINARY
static String	VARCHAR

Constructor Summary

Constructors

Constructor	Description
StarRocksUtils()

Method Summary

Modifier and Type	Method	Description
static String	convertInvalidTimestampDefaultValue(String defaultValue, DataType dataType)
static RecordData.FieldGetter	createFieldGetter(DataType fieldType, int fieldPos, java.time.ZoneId zoneId)	Creates an accessor for getting elements in an internal RecordData structure at the given position.
static void	toStarRocksDataType(Column cdcColumn, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder)
static void	toStarRocksDataType(Column cdcColumn, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder, int unicodeCharMaxBytes)
static void	toStarRocksDataType(DataType cdcDataType, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder)	Convert CDC data type to StarRocks data type.
static void	toStarRocksDataType(DataType cdcDataType, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder, int unicodeCharMaxBytes)
static com.starrocks.connector.flink.catalog.StarRocksTable	toStarRocksTable(TableId tableId, Schema schema, TableCreateConfig tableCreateConfig)	Convert a source table to StarRocksTable.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DATETIME

public static final String DEFAULT_DATETIME

See Also:

Constant Field Values

INVALID_OR_MISSING_DATATIME

public static final String INVALID_OR_MISSING_DATATIME

See Also:

Constant Field Values

BOOLEAN

public static final String BOOLEAN

See Also:

Constant Field Values

TINYINT

public static final String TINYINT

See Also:

Constant Field Values

SMALLINT

public static final String SMALLINT

See Also:

Constant Field Values

INT

public static final String INT

See Also:

Constant Field Values

BIGINT

public static final String BIGINT

See Also:

Constant Field Values

LARGEINT

public static final String LARGEINT

See Also:

Constant Field Values

FLOAT

public static final String FLOAT

See Also:

Constant Field Values

DOUBLE

public static final String DOUBLE

See Also:

Constant Field Values

DECIMAL

public static final String DECIMAL

See Also:

Constant Field Values

CHAR

public static final String CHAR

See Also:

Constant Field Values

VARCHAR

public static final String VARCHAR

See Also:

Constant Field Values

STRING

public static final String STRING

See Also:

Constant Field Values

DATE

public static final String DATE

See Also:

Constant Field Values

DATETIME

public static final String DATETIME

See Also:

Constant Field Values

VARBINARY

public static final String VARBINARY

See Also:

Constant Field Values

JSON

public static final String JSON

See Also:

Constant Field Values

MAX_CHAR_SIZE

public static final int MAX_CHAR_SIZE

Max size of char type of StarRocks.

See Also:

Constant Field Values

MAX_VARCHAR_SIZE

public static final int MAX_VARCHAR_SIZE

Max size of varchar type of StarRocks.

See Also:

Constant Field Values

MAX_VARBINARY_SIZE

public static final int MAX_VARBINARY_SIZE

Max size of varbinary type of StarRocks.

See Also:

Constant Field Values

Constructor Detail

StarRocksUtils

public StarRocksUtils()

Method Detail

toStarRocksTable

public static com.starrocks.connector.flink.catalog.StarRocksTable toStarRocksTable(TableId tableId,
                                                                                    Schema schema,
                                                                                    TableCreateConfig tableCreateConfig)

Convert a source table to StarRocksTable.

toStarRocksDataType

public static void toStarRocksDataType(DataType cdcDataType,
                                       boolean isPrimaryKeys,
                                       com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder)

Convert CDC data type to StarRocks data type.

toStarRocksDataType

public static void toStarRocksDataType(DataType cdcDataType,
                                       boolean isPrimaryKeys,
                                       com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder,
                                       int unicodeCharMaxBytes)

toStarRocksDataType

public static void toStarRocksDataType(Column cdcColumn,
                                       boolean isPrimaryKeys,
                                       com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder)

toStarRocksDataType

public static void toStarRocksDataType(Column cdcColumn,
                                       boolean isPrimaryKeys,
                                       com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder,
                                       int unicodeCharMaxBytes)

createFieldGetter

public static RecordData.FieldGetter createFieldGetter(DataType fieldType,
                                                       int fieldPos,
                                                       java.time.ZoneId zoneId)

Creates an accessor for getting elements in an internal RecordData structure at the given position.

Parameters:

fieldType - the element type of the RecordData

fieldPos - the element position of the RecordData

zoneId - the time zone used when converting from TIMESTAMP WITH LOCAL TIME ZONE

convertInvalidTimestampDefaultValue

public static String convertInvalidTimestampDefaultValue(String defaultValue,
                                                         DataType dataType)