This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch full_outer_join
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3e0980d7466 fix coalesce
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 3140521f548 [region migration] Catch Ratis Read InterruptedException
#13612
add 2a31c57398f Fix fill aligned chunk metadata by schema list (#13560)
add 3c1eace43f0 Change the error infomation when insert a timestamp over
Long.MaxValue (#13597)
add dce69e7f3d6 Subscription: register metrics to count the number of pipe
events in sink queue and prefetching queue in subscription task (#13575)
add 59475a6a603 Load: Fix the source parameter of the load tsfile script
cannot specify a file (#13617)
add ee9b752bacc AINode: Correcting the Omissions and Redundancies (#13594)
add 01370932799 Feature/show ainodes command (#13592)
add be886e3794b fix conflict
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 9 +
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 11 +-
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 4 +-
iotdb-core/ainode/pyproject.toml | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 12 +-
.../consensus/request/ConfigPhysicalPlan.java | 40 ++++
.../read/ainode/GetAINodeConfigurationPlan.java | 21 +-
.../request/read/model/GetModelInfoPlan.java | 22 ++-
.../request/read/model/ShowModelPlan.java | 24 +++
.../protocol/IoTDBConfigRegionConnector.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 9 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 ++-
.../client/IoTDBDataNodeSyncClientManager.java | 26 +--
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 3 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../handler/AINodeRPCServiceThriftHandler.java | 60 ------
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 ------------------
.../thrift/impl/IAINodeRPCServiceWithHandler.java | 26 ---
.../execution/executor/RegionReadExecutor.java | 3 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 86 +++++++-
.../execution/config/TreeConfigTaskVisitor.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 88 ++-------
.../config/executor/IConfigTaskExecutor.java | 14 +-
.../config/metadata/CreatePipePluginTask.java | 10 +
.../config/metadata/DropPipePluginTask.java | 7 +
.../metadata/{model => }/ShowAINodesTask.java | 11 +-
.../config/metadata/ShowDataNodesTask.java | 2 +-
...ShowDataNodesTask.java => ShowAINodesTask.java} | 11 +-
.../metadata/relational/ShowConfigNodesTask.java | 9 +-
.../metadata/relational/ShowDataNodesTask.java | 9 +-
.../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 +
.../db/queryengine/plan/parser/ASTVisitor.java | 6 +-
.../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 ++--
.../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 | 40 ++++
.../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 ++---
.../sql/ast/{Relation.java => PipeStatement.java} | 14 +-
.../ast/{ShowDataNodes.java => ShowAINodes.java} | 8 +-
.../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 ++--
.../plan/relational/sql/parser/AstBuilder.java | 218 +++++++++++++++++++++
.../plan/relational/sql/util/SqlFormatter.java | 208 ++++++++++++++++++++
.../plan/relational/type/InternalTypeManager.java | 1 +
.../schemaregion/utils/MetaFormatUtils.java | 5 +-
.../apache/iotdb/db/service/AINodeRPCService.java | 94 ---------
.../iotdb/db/service/AINodeRPCServiceMBean.java | 22 ---
.../java/org/apache/iotdb/db/service/DataNode.java | 4 -
.../iotdb/db/storageengine/StorageEngine.java | 1 +
.../db/storageengine/dataregion/DataRegion.java | 7 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +
.../task/RepairUnsortedFileCompactionTask.java | 84 ++++----
.../execute/task/SettleCompactionTask.java | 30 +--
.../utils/AlignedSeriesBatchCompactionUtils.java | 10 +-
.../compaction/repair/RepairDataFileScanUtil.java | 12 ++
.../repair/RepairTimePartitionScanTask.java | 3 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 2 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 4 +
.../impl/SizeTieredCompactionSelector.java | 12 +-
.../dataregion/tsfile/TsFileRepairStatus.java | 16 +-
.../agent/SubscriptionBrokerAgent.java | 10 +
.../db/subscription/broker/SubscriptionBroker.java | 20 ++
.../broker/SubscriptionPrefetchingQueue.java | 14 +-
.../db/subscription/event/SubscriptionEvent.java | 6 +
.../batch/SubscriptionPipeTabletEventBatch.java | 10 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 12 +-
.../event/pipe/SubscriptionPipeEmptyEvent.java | 9 +
.../event/pipe/SubscriptionPipeEvents.java | 4 +
.../pipe/SubscriptionPipeTabletBatchEvents.java | 9 +
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 13 ++
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 9 +
.../SubscriptionPrefetchingQueueMetrics.java | 2 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 14 ++
.../SubscriptionConnectorSubtaskManager.java | 3 +
.../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/BatchCompactionUtilsTest.java | 138 +++++++++++++
.../compaction/utils/CompactionTaskQueueTest.java | 8 +-
.../conf/iotdb-system.properties.template | 8 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 1 +
.../config/constant/PipeExtractorConstant.java | 6 +
.../connector/protocol/IoTDBSslSyncConnector.java | 29 +--
.../options/PipeInclusionOptions.java | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 144 +++++++++++++-
.../src/main/thrift/datanode.thrift | 15 +-
pom.xml | 2 +-
117 files changed, 2269 insertions(+), 937 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/AINodeRPCServiceThriftHandler.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/AINodeRPCServiceImpl.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> }/ShowAINodesTask.java (90%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{ShowDataNodesTask.java
=> ShowAINodesTask.java} (91%)
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/{ShowDataNodes.java
=> ShowAINodes.java} (90%)
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%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
