Package org.apache.flink.cdc.connectors.tidb.table.utils

Class TableKeyRangeUtils

java.lang.Object

org.apache.flink.cdc.connectors.tidb.table.utils.TableKeyRangeUtils

public class TableKeyRangeUtils
extends Object

Utils to obtain the keyRange of table.

Constructor Summary

Constructors

Constructor	Description
TableKeyRangeUtils()

Method Summary

Modifier and Type	Method	Description
static org.tikv.kvproto.Coprocessor.KeyRange	getTableKeyRange(long tableId)
static org.tikv.kvproto.Coprocessor.KeyRange	getTableKeyRange(long tableId, int num, int idx)
static List<org.tikv.kvproto.Coprocessor.KeyRange>	getTableKeyRanges(long tableId, int num)
static boolean	isRecordKey(byte[] key)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableKeyRangeUtils

public TableKeyRangeUtils()

Method Detail

getTableKeyRange

public static org.tikv.kvproto.Coprocessor.KeyRange getTableKeyRange(long tableId)

getTableKeyRanges

public static List<org.tikv.kvproto.Coprocessor.KeyRange> getTableKeyRanges(long tableId,
                                                                            int num)

getTableKeyRange

public static org.tikv.kvproto.Coprocessor.KeyRange getTableKeyRange(long tableId,
                                                                     int num,
                                                                     int idx)

isRecordKey

public static boolean isRecordKey(byte[] key)