Package org.apache.flink.cdc.connectors.oracle.util

Class ChunkUtils

java.lang.Object

org.apache.flink.cdc.connectors.oracle.util.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, 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

Method Detail

getSplitType

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

getChunkKeyColumn

public static io.debezium.relational.Column getChunkKeyColumn(io.debezium.relational.Table table,
                                                              @Nullable
                                                              String chunkKeyColumn)