This is an automated email from the ASF dual-hosted git repository.
ColinLeeo pushed a change to branch fix/tablet-out-of-order-seq-overlap
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d1ada1346df Fix the descending expectation of the out-of-order tablet
IT
add 2df4e0f6f68 Guarantee tablet row order outside the write path
No new revisions were added by this update.
Summary of changes:
.../it/insertquery/IoTDBInsertQueryIT.java | 6 +-
.../batch/PipeTabletEventTsFileBatch.java | 8 +-
.../request/PipeTransferTabletRawReq.java | 6 +-
.../request/PipeTransferTabletRawReqV2.java | 12 +--
.../sink/protocol/opcda/OpcDaServerHandle.java | 4 +-
.../process/InsertTabletStatementGenerator.java | 62 --------------
.../TreeInsertTabletStatementGenerator.java | 16 ++++
.../planner/plan/node/write/InsertTabletNode.java | 3 +
.../node/write/RelationalInsertTabletNode.java | 9 ++
.../plan/relational/planner/RelationPlanner.java | 9 ++
.../sorter/InsertEventDataAdapter.java | 5 +-
.../sorter/InsertEventSorter.java} | 52 ++++++++++--
.../sorter/InsertTabletNodeAdapter.java} | 44 +++++-----
.../sorter/InsertTabletStatementAdapter.java | 2 +-
.../sorter/TableModelTabletEventSorter.java} | 88 +++++++++++++++-----
.../sink/util => utils}/sorter/TabletAdapter.java | 2 +-
.../sorter/TreeModelTabletEventSorter.java} | 8 +-
.../db/pipe/sink/PipeStatementEventSorterTest.java | 14 ++--
.../db/pipe/sink/PipeTabletEventSorterTest.java | 14 ++--
.../InsertTabletStatementGeneratorTest.java | 61 --------------
.../tagfilter/TabletTagFilterTest.java | 4 +-
.../sorter/TableModelTabletEventSorterTest.java | 95 ++++++++++++++++++++++
22 files changed, 307 insertions(+), 217 deletions(-)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util
=> utils}/sorter/InsertEventDataAdapter.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util/sorter/PipeInsertEventSorter.java
=> utils/sorter/InsertEventSorter.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util/sorter/InsertTabletStatementAdapter.java
=> utils/sorter/InsertTabletNodeAdapter.java} (66%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util
=> utils}/sorter/InsertTabletStatementAdapter.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util/sorter/PipeTableModelTabletEventSorter.java
=> utils/sorter/TableModelTabletEventSorter.java} (68%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util
=> utils}/sorter/TabletAdapter.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/sink/util/sorter/PipeTreeModelTabletEventSorter.java
=> utils/sorter/TreeModelTabletEventSorter.java} (92%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/sorter/TableModelTabletEventSorterTest.java
