This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/SupportNoMeasurementColumn
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b9154ca69f8 Support no measurement columns in the select clause
add e5e4980331e Support OFFSET XXX LIMIT XXXX in relational model
add 5387a102543 Modify regionMigrateService's ThreadPool to
IoTThreadPoolFactory.cachedThreadPool (#13548)
add 3f922e72c59 Load: New SQL grammer `LOAD <filePath> with ('k'='v',
...)` (#13466)
add 1940261bdce Fix AINode status error after ConfigNode Leader restarts
#13547
add 68eb91af45b Support print plan when assert fails in PlanMatchPattern
add 598cabe238b Keep all null rows in table model compaction (#13523)
add d7888e84f28 Pipe: eliminate progress index for raw tablet event to
avoid endless rebind (#13542)
add 453cd46c26b Pipe: Fixed the bug that the relative path in
OPCUAConnector security dir is not formulated (#13555)
add b339ba86a47 Pipe: optimize the 'Create Pipe' SQL statement to allow
omitting 'With Sink' when no Source or Processor attributes are defined.
(#13534)
add e48b8b925b5 Pipe / Subscription : Fixed the bug that
TsFileInsertionScanDataContainer may use wrong isMultiPage flag for aligned
chunk when value chunk is not continuous (#13554)
add 3ca3f44aec1 Pipe: make progress index immutable (#13544)
new 7aff25dcc35 resolve conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 8 +-
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 11 +
.../it/query/recent/IoTDBNullIdQueryIT.java | 50 ++++
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 22 +-
.../confignode/manager/load/cache/LoadCache.java | 14 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../connector/protocol/opcua/OpcUaConnector.java | 16 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 6 +-
.../scan/TsFileInsertionScanDataContainer.java | 16 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 13 +-
.../PipeTimePartitionProgressIndexKeeper.java | 8 +-
.../processor/aggregate/AggregateProcessor.java | 14 +-
.../twostage/plugin/TwoStageCountProcessor.java | 12 +-
.../operator/source/AlignedSeriesScanOperator.java | 3 +-
.../operator/source/AlignedSeriesScanUtil.java | 7 +-
.../source/relational/TableScanOperator.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 33 ++-
.../plan/planner/plan/node/PlanGraphPrinter.java | 28 +-
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 2 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 14 +-
.../plan/statement/crud/LoadTsFileStatement.java | 18 ++
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 2 +-
.../iotdb/db/service/RegionMigrateService.java | 36 +--
.../db/storageengine/dataregion/DataRegion.java | 8 +-
.../execute/performer/ICompactionPerformer.java | 2 +
.../performer/impl/FastCompactionPerformer.java | 13 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 10 +-
.../RepairUnsortedFileCompactionPerformer.java | 3 +-
.../task/RepairUnsortedFileCompactionTask.java | 20 +-
.../subtask/FastCompactionPerformerSubTask.java | 13 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 42 ++-
...BatchedFastAlignedSeriesCompactionExecutor.java | 56 ++--
...edReadChunkAlignedSeriesCompactionExecutor.java | 60 ++--
.../utils/AlignedSeriesBatchCompactionUtils.java | 20 +-
... CompactionAlignedPageLazyLoadPointReader.java} | 49 ++--
.../fast/FastAlignedSeriesCompactionExecutor.java | 19 +-
.../fast/reader/CompactionAlignedChunkReader.java | 79 +++---
.../ReadChunkAlignedSeriesCompactionExecutor.java | 85 +++---
.../compaction/repair/RepairDataFileScanUtil.java | 2 +-
.../repair/RepairTimePartitionScanTask.java | 6 +-
.../schedule/CompactionScheduleContext.java | 40 ++-
.../compaction/schedule/CompactionScheduler.java | 15 +-
.../selector/constant/CrossCompactionSelector.java | 6 +-
.../constant/InnerSequenceCompactionSelector.java | 2 +-
.../InnerUnsequenceCompactionSelector.java | 2 +-
.../impl/NewSizeTieredCompactionSelector.java | 4 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 15 +-
.../selector/impl/SettleSelectorImpl.java | 16 +-
.../impl/SizeTieredCompactionSelector.java | 21 +-
.../utils/CrossSpaceCompactionCandidate.java | 4 +-
.../selector/utils/TsFileResourceCandidate.java | 1 +
.../dataregion/tsfile/TsFileResource.java | 4 +-
.../load/config/LoadTsFileConfigurator.java | 100 +++++++
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../TsFileResourceProgressIndexTest.java | 64 +++--
.../compaction/AbstractCompactionTest.java | 3 +-
.../CrossSpaceCompactionWithUnusualCasesTest.java | 37 ++-
...InconsistentCompressionTypeAndEncodingTest.java | 3 +-
.../FastInnerCompactionPerformerTest.java | 2 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 63 +++--
.../CrossSpaceCompactionWithFastPerformerTest.java | 10 +-
...eCompactionWithFastPerformerValidationTest.java | 136 +++++----
...sSpaceCompactionWithReadPointPerformerTest.java | 10 +-
...actionWithReadPointPerformerValidationTest.java | 130 +++++----
.../InsertionCrossSpaceCompactionRecoverTest.java | 13 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 105 ++++---
.../cross/InsertionCrossSpaceCompactionTest.java | 15 +-
.../compaction/cross/MergeUpgradeTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 42 +--
.../inner/InnerSpaceCompactionSelectorTest.java | 25 +-
.../SizeTieredCompactionSelectorTest.java | 7 +-
.../repair/RepairUnsortedFileCompactionTest.java | 28 +-
.../settle/SettleCompactionSelectorTest.java | 63 +++--
.../settle/SettleCompactionTaskTest.java | 4 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 315 +++++++++++++++++++++
.../compaction/utils/BatchCompactionUtilsTest.java | 13 +-
.../compaction/utils/CompactionCheckerUtils.java | 3 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 38 +--
.../commons/consensus/index/ProgressIndex.java | 43 ++-
.../consensus/index/impl/HybridProgressIndex.java | 41 ++-
.../consensus/index/impl/IoTProgressIndex.java | 17 +-
.../consensus/index/impl/MetaProgressIndex.java | 25 +-
.../consensus/index/impl/MinimumProgressIndex.java | 7 +-
.../consensus/index/impl/RecoverProgressIndex.java | 27 +-
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 29 +-
.../index/impl/TimeWindowStateProgressIndex.java | 47 ++-
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 13 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 15 +-
pom.xml | 2 +-
96 files changed, 1674 insertions(+), 819 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/{BatchedCompactionAlignedPagePointReader.java
=> CompactionAlignedPageLazyLoadPointReader.java} (67%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/config/LoadTsFileConfigurator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/CompactionWithAllNullRowsTest.java
