Package org.apache.flink.cdc.connectors.mysql.source.utils

Class ChunkUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.utils.ChunkUtils

public class ChunkUtils
extends Object

Utilities to split chunks of table.

Method Summary

Modifier and Type	Method	Description
static io.debezium.relational.Column	getChunkKeyColumn(io.debezium.relational.Table table, Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns)	Get the chunk key column.
static org.apache.flink.table.types.logical.RowType	getChunkKeyColumnType(io.debezium.relational.Column chunkKeyColumn, boolean tinyInt1isBit)
static org.apache.flink.table.types.logical.RowType	getChunkKeyColumnType(io.debezium.relational.Table table, Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns, boolean tinyInt1isBit)
static int	getNextMetaGroupId(int receivedMetaNum, int metaGroupSize)	Returns next meta group id according to received meta number and meta group size.

Methods inherited from class java.lang.Object

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

Method Detail

getChunkKeyColumnType

public static org.apache.flink.table.types.logical.RowType getChunkKeyColumnType(io.debezium.relational.Table table,
                                                                                 Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns,
                                                                                 boolean tinyInt1isBit)

getChunkKeyColumnType

public static org.apache.flink.table.types.logical.RowType getChunkKeyColumnType(io.debezium.relational.Column chunkKeyColumn,
                                                                                 boolean tinyInt1isBit)

getChunkKeyColumn

public static io.debezium.relational.Column getChunkKeyColumn(io.debezium.relational.Table table,
                                                              Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns)

Get the chunk key column. This column could be set by `chunkKeyColumn`. If the table doesn't have primary keys, `chunkKeyColumn` must be set. When the parameter `chunkKeyColumn` is not set and the table has primary keys, return the first column of primary keys.

getNextMetaGroupId

public static int getNextMetaGroupId(int receivedMetaNum,
                                     int metaGroupSize)

Returns next meta group id according to received meta number and meta group size.