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

Class ChunkUtils

java.lang.Object

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

public class ChunkUtils
extends Object

Utilities to split chunks of table.

Constructor Summary

Constructors

Constructor	Description
ChunkUtils()

Method Summary

Modifier and Type	Method	Description
static io.debezium.relational.Column	getSplitColumn(io.debezium.relational.Table table, String chunkKeyColumn)
static org.apache.flink.table.types.logical.RowType	getSplitType(io.debezium.relational.Column splitColumn)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChunkUtils

public ChunkUtils()

Method Detail

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,
                                                           @Nullable
                                                           String chunkKeyColumn)