This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix-partial-insert-null-columns
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 91dd4ebb994 Fix partial insert handling for null measurements
add cfe622fff76 Fix partial insert handling for missing columns
No new revisions were added by this update.
Summary of changes:
.../tablet/parser/TabletInsertionEventParser.java | 10 +-
.../statement/PipeConvertedInsertRowStatement.java | 6 +
.../plan/analyze/schema/NormalSchemaFetcher.java | 4 +-
.../plan/planner/plan/node/write/InsertNode.java | 25 ++-
.../planner/plan/node/write/InsertRowNode.java | 177 ++++++++++++-----
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +-
.../plan/node/write/RelationalInsertRowNode.java | 38 +++-
.../plan/node/write/RelationalInsertRowsNode.java | 33 +++-
.../node/write/RelationalInsertTabletNode.java | 54 ++++--
.../fetcher/cache/TreeDeviceNormalSchema.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +-
.../plan/relational/sql/ast/InsertRow.java | 5 +-
.../plan/relational/sql/ast/InsertRows.java | 14 +-
.../plan/relational/sql/ast/InsertTablet.java | 13 +-
.../relational/sql/ast/WrappedInsertStatement.java | 22 ++-
.../plan/statement/crud/InsertBaseStatement.java | 49 +++--
.../plan/statement/crud/InsertRowStatement.java | 65 ++++++-
.../crud/InsertRowsOfOneDeviceStatement.java | 12 ++
.../plan/statement/crud/InsertTabletStatement.java | 105 +++++++++--
.../db/storageengine/dataregion/DataRegion.java | 3 +-
.../dataregion/memtable/AbstractMemTable.java | 120 ++++++++----
.../dataregion/memtable/TsFileProcessor.java | 35 ++--
.../consensus/ConsensusLogToTabletConverter.java | 70 +++++--
.../db/trigger/executor/TriggerFireVisitor.java | 53 +++++-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 33 +++-
.../sink/util/TabletStatementConverterTest.java | 28 +++
.../planner/node/write/InsertRowNodeSerdeTest.java | 108 +++++++++++
.../node/write/InsertRowsNodeSerdeTest.java | 35 ++++
.../node/write/InsertTabletNodeSerdeTest.java | 28 +++
.../crud/InsertStatementPartialInsertTest.java | 209 +++++++++++++++++++++
.../ConsensusLogToTabletConverterTest.java | 58 ++++++
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 49 +++++
32 files changed, 1259 insertions(+), 219 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertStatementPartialInsertTest.java
