org.apache.shardingsphere.data.pipeline.core.importer

类 DataRecordMerger

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.importer.DataRecordMerger

public final class DataRecordMerger
extends Object

Data Record merger.

构造器概要

构造器

构造器和说明
DataRecordMerger()

方法概要

限定符和类型	方法和说明
List<GroupedDataRecord>	group(List<DataRecord> dataRecords) Group by table and type.
List<DataRecord>	merge(List<DataRecord> dataRecords) Merge data record.

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

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

构造器详细资料

DataRecordMerger

public DataRecordMerger()

方法详细资料

merge

public List<DataRecord> merge(List<DataRecord> dataRecords)

Merge data record.

 insert + insert -> exception
 update + insert -> exception
 delete + insert -> insert
 insert + update -> insert
 update + update -> update
 delete + update -> exception
 insert + delete -> delete
 update + delete -> delete
 delete + delete -> exception
 

参数:

dataRecords - data records

返回:

merged data records

group

public List<GroupedDataRecord> group(List<DataRecord> dataRecords)

Group by table and type.

参数:

dataRecords - data records

返回:

grouped data records