com.ververica.cdc.connectors.mysql.source.utils

Class ChunkUtils

java.lang.Object

com.ververica.cdc.connectors.mysql.source.utils.ChunkUtils

public class ChunkUtils
extends Object

Utilities to split chunks of table.

Method Summary

Modifier and Type	Method and Description
static int	getNextMetaGroupId(int receivedMetaNum, int metaGroupSize) Returns next meta group id according to received meta number and meta group size.
static io.debezium.relational.Column	getSplitColumn(io.debezium.relational.Table table)
static org.apache.flink.table.types.logical.RowType	getSplitType(io.debezium.relational.Column splitColumn)
static org.apache.flink.table.types.logical.RowType	getSplitType(io.debezium.relational.Table table)

Methods inherited from class java.lang.Object

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

Method Detail

getSplitType

public static org.apache.flink.table.types.logical.RowType getSplitType(io.debezium.relational.Table table)

getSplitType

public static org.apache.flink.table.types.logical.RowType getSplitType(io.debezium.relational.Column splitColumn)

getSplitColumn

public static io.debezium.relational.Column getSplitColumn(io.debezium.relational.Table table)

getNextMetaGroupId

public static int getNextMetaGroupId(int receivedMetaNum,
                                     int metaGroupSize)

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