org.apache.shardingsphere.data.pipeline.core.record

类 RecordUtil

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.record.RecordUtil

public final class RecordUtil
extends Object

Record utility.

构造器概要

构造器

构造器和说明
RecordUtil()

方法概要

限定符和类型	方法和说明
static List<Column>	extractConditionColumns(DataRecord dataRecord, Set<String> shardingColumns) Extract condition columns(include primary and sharding columns) from data record.
static List<Column>	extractPrimaryColumns(DataRecord dataRecord) Extract primary columns from data record.
static List<Column>	extractUpdatedColumns(DataRecord dataRecord) Extract updated columns from data record.

从类继承的方法 java.lang.Object

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

构造器详细资料

RecordUtil

public RecordUtil()

方法详细资料

extractPrimaryColumns

public static List<Column> extractPrimaryColumns(DataRecord dataRecord)

Extract primary columns from data record.

参数:

dataRecord - data record

返回:

primary columns

extractConditionColumns

public static List<Column> extractConditionColumns(DataRecord dataRecord,
                                                   Set<String> shardingColumns)

Extract condition columns(include primary and sharding columns) from data record.

参数:

dataRecord - data record

shardingColumns - sharding columns

返回:

condition columns

extractUpdatedColumns

public static List<Column> extractUpdatedColumns(DataRecord dataRecord)

Extract updated columns from data record.

参数:

dataRecord - data record

返回:

updated columns