This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch support_table_model_redirect
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 594a4d28267 fix IT
add 3d2222a221e change back
add 1df5d6de87f fix table mode session pool issue and add IT
add 2306afe84d8 fix IT bug
add a5c5c69b5d9 fix split tablet error and add IT
add 2f57ea327dc optimize first insert profermance
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 db3317d20f8 Merge branch 'master' of github.com:apache/iotdb into
support_table_model_redirect
No new revisions were added by this update.
Summary of changes:
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 11 +
.../pool/IoTDBInsertTableSessionPoolIT.java | 245 ++++++++++++++++
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 76 +++++
.../org/apache/iotdb/isession/IPooledSession.java | 1 +
.../java/org/apache/iotdb/isession/ISession.java | 8 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 1 -
.../java/org/apache/iotdb/session/Session.java | 79 ++++--
.../org/apache/iotdb/session/pool/SessionPool.java | 25 +-
.../apache/iotdb/session/pool/SessionWrapper.java | 8 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../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 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 13 +-
.../PipeTimePartitionProgressIndexKeeper.java | 6 +-
.../operator/source/AlignedSeriesScanOperator.java | 3 +-
.../operator/source/AlignedSeriesScanUtil.java | 7 +-
.../source/relational/TableScanOperator.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 11 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 28 +-
.../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 +
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../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 +--
75 files changed, 1679 insertions(+), 595 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/pool/IoTDBInsertTableSessionPoolIT.java
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/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/CompactionWithAllNullRowsTest.java
