This is an automated email from the ASF dual-hosted git repository.
ycycse pushed a change to branch FillAINode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a4f2437ef74 remove AINodeService in datanode which is not used anymore.
add cb4befcbd45 fix bug (#13590)
add 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
add 197965e9ae9 Skip the file timestamp check of tsfiles generated by
repair task (#13581)
add 737c4ccea98 Fix print error log when dir is not exist (#13591)
add 5b22e7b010b Handle commit failure of table procedures
add ed8f61cb38d Update tsfile version to 1.2.0-240924-SNAPSHOT (#13603)
add 1ded38ce5fd Optimized the error log for illegal database names in tree
model
add 98addd823bc Pipe: basic support for table model from SQL to
IConfigTask (#13600)
add 905c2e2af03 Support syntactic sugar of aggregation function last and
first in TableModel (#13596)
add 9dda5d93acf Add CoalesceExpression support
add 9ed645db6cc Pipe: Fix relative path in SSLConnector trustStorePath is
not formulated & Fix inclusion option 'delete' fails to parse (#13580)
add 040dcf18236 Pipe: basic support for table model (a follow-up fix for
#13600) (#13611)
add 1ed2023d01c Fix compaction with all null rows ut (#13610)
add fc6eef2d636 Enhance repair compaction & exception handle with full
disks (#13602)
add 1447d41ccf5 Fix push-down level of global aggregation in TableModel
add d0c0fd76473 Make last_by, first_by with time can push-down in
TableModel
add 8a50d59eb2d Pipe: Added count-point-processor to black list (#13605)
add d5c854d6eb2 Pipe: Fix null output-series device issue in Two-Stage
Processor (#13604)
add 035770f82e2 Merge remote-tracking branch 'origin/master' into
FillAINode
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 11 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 19 ++
.../iotdb/confignode/conf/ConfigNodeConfig.java | 12 +-
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../{ShowTablePlan.java => FetchTablePlan.java} | 17 +-
.../{ShowTableResp.java => FetchTableResp.java} | 21 +-
.../iotdb/confignode/manager/ConfigManager.java | 23 +++
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 16 +-
.../protocol/IoTDBConfigRegionConnector.java | 3 +-
.../manager/schema/ClusterSchemaManager.java | 16 ++
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 23 +++
.../confignode/persistence/schema/ConfigMTree.java | 17 ++
.../impl/schema/table/AddTableColumnProcedure.java | 1 -
.../impl/schema/table/CreateTableProcedure.java | 1 -
.../schema/table/SetTablePropertiesProcedure.java | 1 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 ++
.../client/IoTDBDataNodeSyncClientManager.java | 26 +--
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 3 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../relational/ColumnTransformerBuilder.java | 23 ++-
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +-
.../execution/config/TableConfigTaskVisitor.java | 72 +++++++
.../config/executor/ClusterConfigTaskExecutor.java | 22 ++-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../config/metadata/CreatePipePluginTask.java | 10 +
.../config/metadata/DropPipePluginTask.java | 7 +
.../execution/config/sys/pipe/AlterPipeTask.java | 14 ++
.../execution/config/sys/pipe/CreatePipeTask.java | 11 ++
.../execution/config/sys/pipe/DropPipeTask.java | 8 +
.../execution/config/sys/pipe/ShowPipeTask.java | 7 +
.../execution/config/sys/pipe/StartPipeTask.java | 7 +
.../execution/config/sys/pipe/StopPipeTask.java | 7 +
.../plan/parser/StatementGenerator.java | 11 +-
.../relational/analyzer/ExpressionTreeUtils.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 54 +++++
.../plan/relational/metadata/Metadata.java | 3 +-
.../metadata/TableBuiltinAggregationFunction.java | 12 +-
.../relational/metadata/TableMetadataImpl.java | 43 ++--
.../fetcher/TableHeaderSchemaValidator.java | 60 ++++--
.../distribute/TableDistributedPlanner.java | 7 +
.../TableModelTypeProviderExtractor.java | 11 +-
.../PushAggregationIntoTableScan.java | 14 +-
.../relational/planner/optimizations/Util.java | 7 +-
.../plan/relational/sql/ast/AlterPipe.java | 143 ++++++++++++++
.../plan/relational/sql/ast/AstVisitor.java | 36 ++++
.../relational/sql/ast/CoalesceExpression.java | 28 +++
.../plan/relational/sql/ast/CreatePipe.java | 113 +++++++++++
.../plan/relational/sql/ast/CreatePipePlugin.java | 95 +++++++++
.../sql/ast/{JoinUsing.java => DropPipe.java} | 55 +++---
.../sql/ast/{Explain.java => DropPipePlugin.java} | 44 ++---
.../plan/relational/sql/ast/Expression.java | 3 +
.../sql/ast/{Relation.java => PipeStatement.java} | 14 +-
.../ast/{NaturalJoin.java => ShowPipePlugins.java} | 24 +--
.../sql/ast/{JoinUsing.java => ShowPipes.java} | 56 +++---
.../ast/{ShowConfigNodes.java => StartPipe.java} | 33 ++--
.../sql/ast/{ShowDataNodes.java => StopPipe.java} | 33 ++--
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 212 ++++++++++++++++++++
.../plan/relational/sql/util/SqlFormatter.java | 208 ++++++++++++++++++++
.../plan/relational/type/InternalTypeManager.java | 1 +
...sformer.java => CoalesceColumnTransformer.java} | 29 +--
.../schemaregion/utils/MetaFormatUtils.java | 5 +-
.../db/schemaengine/table/DataNodeTableCache.java | 217 ++++++++++++++++-----
.../iotdb/db/storageengine/StorageEngine.java | 1 +
.../db/storageengine/dataregion/DataRegion.java | 16 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/task/AbstractCompactionTask.java | 4 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 88 ++++-----
.../execute/task/SettleCompactionTask.java | 30 +--
.../compaction/repair/RepairDataFileScanUtil.java | 22 ++-
.../repair/RepairTimePartitionScanTask.java | 5 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 2 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 4 +
.../impl/SizeTieredCompactionSelector.java | 12 +-
.../dataregion/tsfile/TsFileRepairStatus.java | 16 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../FileTimeIndexCacheWriter.java | 8 +-
.../iotdb/db/utils/constant/SqlConstant.java | 5 +
.../plan/relational/analyzer/AggregationTest.java | 171 ++++++++++++----
.../plan/relational/analyzer/TSBSMetadata.java | 5 +-
.../plan/relational/analyzer/TSBSTest.java | 1 +
.../plan/relational/analyzer/TestMatadata.java | 5 +-
.../assertions/AggregationTableScanMatcher.java | 11 +-
.../planner/assertions/PlanMatchPattern.java | 2 +-
.../repair/RepairUnsortedFileCompactionTest.java | 100 +++++++++-
.../repair/RepairUnsortedFileSchedulerTest.java | 2 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 2 +
.../compaction/utils/CompactionTaskQueueTest.java | 8 +-
.../conf/iotdb-system.properties.template | 5 +
.../agent/plugin/builtin/BuiltinPipePlugin.java | 1 +
.../config/constant/PipeExtractorConstant.java | 6 +
.../connector/protocol/IoTDBSslSyncConnector.java | 29 +--
.../options/PipeInclusionOptions.java | 2 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +-
.../schema/table/TsTableInternalRPCUtil.java | 94 ++++++---
.../org/apache/iotdb/commons/utils/PathUtils.java | 7 +
.../db/relational/grammar/sql/RelationalSql.g4 | 138 ++++++++++++-
.../src/main/thrift/confignode.thrift | 7 +
pom.xml | 2 +-
108 files changed, 2389 insertions(+), 508 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/{ShowTablePlan.java
=> FetchTablePlan.java} (72%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{ShowTableResp.java
=> FetchTableResp.java} (61%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{JoinUsing.java
=> DropPipe.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Explain.java
=> DropPipePlugin.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Relation.java
=> PipeStatement.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NaturalJoin.java
=> ShowPipePlugins.java} (77%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{JoinUsing.java
=> ShowPipes.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowConfigNodes.java
=> StartPipe.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowDataNodes.java
=> StopPipe.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/{InMultiColumnTransformer.java
=> CoalesceColumnTransformer.java} (72%)
