This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b01242d5eaf Update TsFileInsertionEventParserTest.java
add 50cefa2527b Pipe: Fixed the OOM bug of parser for large aligned pages
(#17639)
add 5029a0aa88e Load: Harden LOAD TSFILE source path validation (#17624)
add e4fc7582bc4 Pipe: Optimized the thread executor of the terminate event
(#17638)
add ed7f4d7b55c Fix nested transformer close and move shared classes
(#17642)
add 7cc991806ea Fix typo in contributing guide (#17650)
add 4b2946e799d Fix that partial insert with nulls may result in negative
inserted point count (#17640)
add b70583e204b Merge branch 'master' of https://github.com/apache/iotdb
into test
No new revisions were added by this update.
Summary of changes:
CONTRIBUTING.md | 3 +-
.../iotdb/calc}/execution/schedule/queue/ID.java | 2 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 4 +-
.../queue/IndexedBlockingReserveQueue.java | 2 +-
.../AbstractCaseWhenThenColumnTransformer.java | 11 +
.../dag/column/binary/BinaryColumnTransformer.java | 7 +
.../column/multi/MappableUDFColumnTransformer.java | 4 +
.../dag/column/multi/MultiColumnTransformer.java | 8 +
.../column/ternary/TernaryColumnTransformer.java | 8 +
.../dag/column/unary/UnaryColumnTransformer.java | 6 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 83 ++++++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 27 ++
.../common/deletion/PipeDeleteDataNodeEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../event/common/terminate/PipeTerminateEvent.java | 31 ++-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 54 +++-
.../parser/scan/EstimatedMemoryChunkReader.java} | 8 +-
.../parser/scan/SinglePageWholeChunkReader.java | 28 +-
.../scan/TsFileInsertionEventScanParser.java | 121 ++++++++-
.../table/TsFileInsertionEventTableParser.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../matcher/CachedSchemaPatternMatcher.java | 2 +-
.../PipePlanTablePrivilegeParseVisitor.java | 2 +-
.../execution/fragment/DataNodeQueryContext.java | 2 +-
.../fragment/FragmentInstanceManager.java | 2 +-
.../relational/LastQueryAggTableScanOperator.java | 2 +-
.../execution/schedule/AbstractDriverThread.java | 2 +-
.../execution/schedule/DriverScheduler.java | 4 +-
.../execution/schedule/DriverTaskThread.java | 2 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../execution/schedule/ThreadProducer.java | 2 +-
.../execution/schedule/queue/L1PriorityQueue.java | 6 +-
.../execution/schedule/queue/L2PriorityQueue.java | 22 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 4 +-
.../execution/schedule/task/DriverTask.java | 4 +-
.../execution/schedule/task/DriverTaskId.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 10 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 2 +-
.../planner/DataNodeTableOperatorGenerator.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 4 +
.../plan/relational/analyzer/Analysis.java | 2 +-
.../relational/analyzer/ExpressionAnalyzer.java | 2 +-
.../plan/relational/analyzer/Field.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 4 +-
.../plan/relational/metadata/Metadata.java | 1 +
.../relational/metadata/QualifiedTablePrefix.java | 6 +-
.../relational/metadata/TableMetadataImpl.java | 1 +
.../fetcher/TableHeaderSchemaValidator.java | 2 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 2 +-
.../plan/relational/planner/RelationPlanner.java | 4 +-
.../relational/planner/TableLogicalPlanner.java | 4 +-
.../planner/distribute/AddExchangeNodes.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 2 +-
.../distribute/TableModelQueryFragmentPlanner.java | 2 +-
.../TableModelTypeProviderExtractor.java | 2 +-
.../rule/EliminateLimitProjectWithTableScan.java | 2 +-
.../rule/EliminateLimitWithTableScan.java | 2 +-
.../iterative/rule/PruneTableScanColumns.java | 2 +-
.../rule/PushDownOffsetIntoTableScan.java | 2 +-
.../planner/node/AggregationTableScanNode.java | 2 +-
.../node/AggregationTreeDeviceViewScanNode.java | 2 +-
.../AlignedAggregationTreeDeviceViewScanNode.java | 2 +-
.../planner/node/DeviceTableScanNode.java | 3 +-
.../node/InformationSchemaTableScanNode.java | 3 +-
...onAlignedAggregationTreeDeviceViewScanNode.java | 2 +-
.../plan/relational/planner/node/Patterns.java | 1 +
...bleDiskUsageInformationSchemaTableScanNode.java | 3 +-
.../node/TreeAlignedDeviceViewScanNode.java | 2 +-
.../planner/node/TreeDeviceViewScanNode.java | 2 +-
.../node/TreeNonAlignedDeviceViewScanNode.java | 2 +-
.../PushLimitOffsetIntoTableScan.java | 2 +-
.../optimizations/PushPredicateIntoTableScan.java | 2 +-
.../plan/relational/security/AccessControl.java | 2 +-
.../relational/security/AccessControlImpl.java | 2 +-
.../relational/security/AllowAllAccessControl.java | 2 +-
.../relational/security/ITableAuthChecker.java | 2 +-
.../relational/security/ITableAuthCheckerImpl.java | 2 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 4 +-
.../plan/relational/sql/ast/LoadTsFile.java | 17 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 4 +-
.../plan/statement/crud/LoadTsFileStatement.java | 72 ++++-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +
.../iotdb/db/storageengine/StorageEngine.java | 2 -
.../db/storageengine/dataregion/DataRegion.java | 20 --
.../exception/StopTTLCheckException.java} | 8 +-
.../compaction/execute/utils/CompactionUtils.java | 154 -----------
.../schedule/CompactionScheduleTaskManager.java | 1 +
.../compaction/schedule/TTLScheduleTask.java | 15 +-
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../pipe/event/PipeTsFileInsertionEventTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 141 ++++++++++
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 2 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 2 +-
.../schedule/queue/L1PriorityQueueTest.java | 2 +
.../schedule/queue/L2PriorityQueueTest.java | 2 +
.../queue/MultilevelPriorityQueueTest.java | 1 +
.../execution/schedule/queue/QueueElement.java | 9 +-
.../planner/node/source/SourceNodeSerdeTest.java | 2 +-
.../write/InsertNodeIsMeasurementFailedTest.java | 174 ++++++++++++
.../plan/relational/analyzer/AnalyzerTest.java | 2 +-
.../plan/relational/analyzer/AuthTest.java | 2 +-
.../plan/relational/analyzer/TSBSMetadata.java | 2 +-
.../plan/relational/analyzer/TestMetadata.java | 2 +-
.../plan/relational/analyzer/TestPlanBuilder.java | 2 +-
.../planner/assertions/ColumnReference.java | 2 +-
.../planner/assertions/TableScanMatcher.java | 2 +-
.../statement/crud/LoadTsFileStatementTest.java | 60 +++++
.../AbstractMemTablePartialInsertTest.java | 297 +++++++++++++++++++++
.../conf/iotdb-system.properties.template | 11 +
.../planner/plan/node/ICoreQueryPlanVisitor.java | 1 -
.../plan/planner/plan}/node/TableScanNode.java | 8 +-
.../plan/relational/metadata/MetadataUtil.java | 2 +-
.../relational/metadata/QualifiedObjectName.java | 4 +-
120 files changed, 1277 insertions(+), 356 deletions(-)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/schedule/queue/ID.java
(93%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/schedule/queue/IDIndexedAccessible.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/schedule/queue/IndexedBlockingQueue.java
(98%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/schedule/queue/IndexedBlockingReserveQueue.java
(97%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/analyzer/CorrelationSupport.java
=> pipe/event/common/tsfile/parser/scan/EstimatedMemoryChunkReader.java} (83%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{repair/RepairTaskStatus.java
=> execute/exception/StopTTLCheckException.java} (91%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertNodeIsMeasurementFailedTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractMemTablePartialInsertTest.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/{db/queryengine/plan/relational/planner
=> commons/queryengine/plan/planner/plan}/node/TableScanNode.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/{db =>
commons}/queryengine/plan/relational/metadata/MetadataUtil.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/{db =>
commons}/queryengine/plan/relational/metadata/QualifiedObjectName.java (94%)
