This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch agg_table_scan
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d27be355be4 tmp
add 697871705ec Refactor: Removed the useless Ser/de logic in configNode
read plans (#13577)
add 5de8dc7a4db IoTConsensusV2: Introduce IoTConsensusV2 and corresponding
mode option (#13440)
add acda1a0f092 Make log dispatcher stop in parallel #13588
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 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 99037029548 Fix the error in aggregation merge sort when device
locates in multi data regions
add 734786f09e4 Fixed database names in "show regions" in table model
add 574bbd1b2ba Feature/dependency check (#13587)
add 374deefeb86 Update ConfigPhysicalReadPlan.java (#13624)
add c4f17560624 Pipe: Fixed the bug that different types in schema
snapshot transfer may cause transfer failure (#13627)
add e7a37dc03ab Pipe: Fixed the bug that alter source will not alter the
reference count of ConfigRegionListeningQueue (#13626)
add aa2fc4c326c [RatisConsensus] Bump ratis version to 3.1.1 #13629
add b9a181a1cd9 Fix NodeInfo processLoadSnapshot method (avoid
compatibility issues caused by ainode serialization) (#13622)
add cd3e8af7e47 Make each execution acquire a schema read lock only once
add 43d07b52a25 Support table model insert redirection (#13550)
add 879715174f2 PipePlugin: Add pipe consensus related plugins to
blackList (#13642)
add 8753985882d Pipe: Fix the problem of missing precision when converting
String type to Int32 and int64 types (#13643)
add 6742d4bdf82 Add full outer time join for table model
new a37c2f0adaf merge master
new 3c17c2563f4 fix conflict in SqlConstant
add bf0666e096c Support global-aggregation in TableModel
new 9452d6f0f6f Merge branch 'master' into agg_table_scan
new 69636508279 tmp
new 22f30d046f1 tmp
The 5 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:
.github/workflows/dependency-check.yml | 59 +++
dependencies.json | 167 +++++++
.../iotdb/it/env/cluster/ClusterConstant.java | 4 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +-
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 9 +
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 11 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 20 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 185 ++++++++
.../pool/IoTDBInsertTableSessionPoolIT.java | 245 ++++++++++
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 76 ++++
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 4 +-
.../org/apache/iotdb/isession/IPooledSession.java | 1 +
.../java/org/apache/iotdb/isession/ISession.java | 9 +
.../org/apache/iotdb/rpc/RedirectException.java | 15 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 17 +
.../java/org/apache/iotdb/session/Session.java | 216 ++++++++-
.../apache/iotdb/session/SessionConnection.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 22 +-
.../apache/iotdb/session/pool/SessionWrapper.java | 8 +-
.../iotdb/session/SessionCacheLeaderTest.java | 271 ++++++++++-
.../iotdb/session/SessionConnectionTest.java | 2 +-
iotdb-core/ainode/pyproject.toml | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 12 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../consensus/request/ConfigPhysicalPlan.java | 202 ++-------
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 2 +-
...PipePlanV2.java => ConfigPhysicalReadPlan.java} | 14 +-
.../read/ainode/GetAINodeConfigurationPlan.java | 12 +-
.../request/read/auth/AuthorReadPlan.java | 143 ++++++
.../consensus/request/read/cq/ShowCQPlan.java} | 13 +-
.../request/read/database/CountDatabasePlan.java | 51 +--
.../request/read/database/GetDatabasePlan.java | 6 +-
.../datanode/GetDataNodeConfigurationPlan.java | 30 +-
.../read/function/GetFunctionTablePlan.java | 18 +-
.../request/read/function/GetUDFJarPlan.java | 42 +-
.../request/read/model/GetModelInfoPlan.java | 10 +-
.../request/read/model/ShowModelPlan.java | 10 +-
.../read/partition/CountTimeSlotListPlan.java | 49 +-
.../read/partition/GetDataPartitionPlan.java | 66 +--
.../read/partition/GetNodePathsPartitionPlan.java | 33 +-
.../partition/GetOrCreateDataPartitionPlan.java | 10 +-
.../partition/GetOrCreateSchemaPartitionPlan.java | 3 +-
.../read/partition/GetSchemaPartitionPlan.java | 58 +--
.../read/partition/GetSeriesSlotListPlan.java | 36 +-
.../read/partition/GetTimeSlotListPlan.java | 49 +-
.../read/pipe/plugin/GetPipePluginJarPlan.java | 35 +-
.../read/pipe/plugin/GetPipePluginTablePlan.java | 18 +-
.../request/read/pipe/task/ShowPipePlanV2.java | 18 +-
.../request/read/region/GetRegionIdPlan.java | 49 +-
.../request/read/region/GetRegionInfoListPlan.java | 47 +-
.../read/subscription/ShowSubscriptionPlan.java | 18 +-
.../request/read/subscription/ShowTopicPlan.java | 18 +-
.../FetchTablePlan.java} | 20 +-
.../request/read/table/ShowTablePlan.java | 27 +-
.../read/template/CheckTemplateSettablePlan.java | 33 +-
.../read/template/GetAllSchemaTemplatePlan.java | 16 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 16 +-
.../read/template/GetPathsSetTemplatePlan.java | 33 +-
.../read/template/GetSchemaTemplatePlan.java | 32 +-
.../read/template/GetTemplateSetInfoPlan.java | 37 +-
.../read/trigger/GetTransferringTriggersPlan.java | 18 +-
.../request/read/trigger/GetTriggerJarPlan.java | 42 +-
.../read/trigger/GetTriggerLocationPlan.java | 38 +-
.../request/read/trigger/GetTriggerTablePlan.java | 38 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 19 +-
.../request/{ => write}/auth/AuthorPlan.java | 99 +---
.../consensus/request/write/cq/ShowCQPlan.java | 45 --
.../write/partition/RemoveRegionLocationPlan.java | 5 -
.../request/write/sync/ShowPipePlanV1.java | 59 ---
.../consensus/response/table/FetchTableResp.java | 44 ++
.../statemachine/ConfigRegionStateMachine.java | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 36 +-
.../apache/iotdb/confignode/manager/IManager.java | 11 +-
.../iotdb/confignode/manager/ModelManager.java | 10 +-
.../confignode/manager/PermissionManager.java | 9 +-
.../iotdb/confignode/manager/ProcedureManager.java | 18 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 3 -
.../manager/partition/PartitionManager.java | 16 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 13 +-
.../agent/runtime/PipeConfigRegionListener.java | 7 +-
.../protocol/IoTDBConfigRegionConnector.java | 3 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 16 +
.../iotdb/confignode/persistence/AuthorInfo.java | 53 ++-
.../persistence/executor/ConfigPlanExecutor.java | 17 +-
.../confignode/persistence/node/NodeInfo.java | 33 +-
.../confignode/persistence/pipe/PipeInfo.java | 33 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../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 -
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 23 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 482 +-------------------
...eConfigPhysicalPlanPatternParseVisitorTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 82 ++--
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/sync/AuthOperationProcedureTest.java | 29 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 23 +-
.../consensus/config/PipeConsensusConfig.java | 26 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 73 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 57 ++-
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../schemaregion/SchemaExecutionVisitor.java | 12 +
.../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 26 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 4 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 3 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 13 +-
.../transform/converter/ValueConverter.java | 12 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../handler/AINodeRPCServiceThriftHandler.java | 60 ---
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 --------
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 6 +-
.../db/queryengine/common/MPPQueryContext.java | 18 +-
.../execution/aggregation/IAggregator.java | 45 ++
.../{Aggregator.java => TreeAggregator.java} | 6 +-
.../slidingwindow/SlidingWindowAggregator.java | 4 +-
.../execution/executor/RegionReadExecutor.java | 3 +-
.../fragment/FragmentInstanceContext.java | 5 +-
.../execution/operator/AggregationUtil.java | 23 +-
.../process/AggregationMergeSortOperator.java | 3 +-
.../operator/process/AggregationOperator.java | 12 +-
.../process/RawDataAggregationOperator.java | 8 +-
.../process/SingleInputAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 10 +-
.../operator/process/TagAggregationOperator.java | 21 +-
.../operator/process/last/LastQueryUtil.java | 18 +-
.../AbstractSeriesAggregationScanOperator.java | 12 +-
.../AlignedSeriesAggregationScanOperator.java | 6 +-
.../source/SeriesAggregationScanOperator.java | 6 +-
.../TableAggregationTableScanOperator.java | 503 ++++++++++++++++++++-
...erator.java => TableFullOuterJoinOperator.java} | 268 +++++++----
...inOperator.java => TableInnerJoinOperator.java} | 116 ++---
.../source/relational/aggregation/Accumulator.java | 33 ++
.../relational/aggregation/AccumulatorFactory.java | 202 +++++++++
.../aggregation/AggregationOperator.java | 158 +++++++
.../relational/aggregation/AvgAccumulator.java | 191 ++++++++
.../relational/aggregation/CountAccumulator.java | 80 ++++
.../relational/aggregation/TableAggregator.java | 81 ++++
.../operator/window/ConditionWindowManager.java | 6 +-
.../operator/window/CountWindowManager.java | 6 +-
.../execution/operator/window/IWindowManager.java | 15 +-
.../operator/window/SessionWindowManager.java | 6 +-
.../operator/window/TimeWindowManager.java | 6 +-
.../operator/window/VariationWindowManager.java | 6 +-
.../relational/ColumnTransformerBuilder.java | 23 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 6 +-
.../db/queryengine/plan/analyze/Analysis.java | 1 +
.../db/queryengine/plan/analyze/IAnalysis.java | 2 +
.../analyze/lock/DataNodeSchemaLockManager.java | 17 +-
.../execution/config/TableConfigTaskVisitor.java | 90 +++-
.../execution/config/TreeConfigTaskVisitor.java | 16 +-
.../config/executor/ClusterConfigTaskExecutor.java | 135 ++----
.../config/executor/IConfigTaskExecutor.java | 24 +-
.../config/metadata/CreatePipePluginTask.java | 10 +
.../config/metadata/DropPipePluginTask.java | 7 +
.../metadata/{model => }/ShowAINodesTask.java | 11 +-
.../config/metadata/ShowDataNodesTask.java | 2 +-
.../execution/config/metadata/ShowRegionTask.java | 29 +-
...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 +-
.../plan/planner/OperatorTreeGenerator.java | 38 +-
.../plan/planner/TableOperatorGenerator.java | 288 +++++++++++-
.../plan/planner/plan/node/write/InsertNode.java | 1 -
.../planner/plan/node/write/InsertTabletNode.java | 10 +-
.../node/write/RelationalInsertTabletNode.java | 43 ++
.../plan/relational/analyzer/Analysis.java | 5 +
.../relational/analyzer/ExpressionTreeUtils.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 59 ++-
.../plan/relational/metadata/Metadata.java | 3 +-
.../metadata/TableBuiltinAggregationFunction.java | 39 +-
.../relational/metadata/TableMetadataImpl.java | 30 +-
.../fetcher/TableHeaderSchemaValidator.java | 60 ++-
.../plan/relational/planner/RelationPlanner.java | 17 +-
.../plan/relational/planner/TableModelPlanner.java | 40 +-
.../distribute/TableDistributedPlanner.java | 7 +
.../TableModelTypeProviderExtractor.java | 11 +-
.../PushAggregationIntoTableScan.java | 14 +-
.../PushLimitOffsetIntoTableScan.java | 6 +-
.../optimizations/PushPredicateIntoTableScan.java | 9 +-
.../relational/planner/optimizations/Util.java | 7 +-
.../plan/relational/sql/ast/AlterPipe.java | 143 ++++++
.../plan/relational/sql/ast/AstVisitor.java | 40 ++
.../relational/sql/ast/CoalesceExpression.java | 28 ++
.../plan/relational/sql/ast/CreatePipe.java | 113 +++++
.../plan/relational/sql/ast/CreatePipePlugin.java | 95 ++++
.../plan/relational/sql/ast/DropPipe.java | 75 +++
.../plan/relational/sql/ast/DropPipePlugin.java | 75 +++
.../plan/relational/sql/ast/Expression.java | 3 +
.../plan/relational/sql/ast/PipeStatement.java} | 18 +-
.../plan/relational/sql/ast/ShowAINodes.java} | 41 +-
.../plan/relational/sql/ast/ShowPipePlugins.java} | 20 +-
.../plan/relational/sql/ast/ShowPipes.java | 76 ++++
.../plan/relational/sql/ast/StartPipe.java | 65 +++
.../plan/relational/sql/ast/StopPipe.java | 65 +++
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 218 +++++++++
.../plan/relational/sql/util/SqlFormatter.java | 208 +++++++++
.../plan/relational/type/InternalTypeManager.java | 1 +
.../column/multi/CoalesceColumnTransformer.java | 58 +++
.../schemaregion/utils/MetaFormatUtils.java | 5 +-
.../db/schemaengine/table/DataNodeTableCache.java | 217 +++++++--
.../apache/iotdb/db/service/AINodeRPCService.java | 94 ----
.../java/org/apache/iotdb/db/service/DataNode.java | 7 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 17 +-
.../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 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 10 +-
.../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 +-
.../storageengine/dataregion/wal/WALManager.java | 18 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +-
.../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 | 11 +-
.../operator/AggregationMergeSortOperatorTest.java | 177 ++++++++
.../operator/AggregationOperatorTest.java | 10 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 73 +--
.../operator/HorizontallyConcatOperatorTest.java | 6 +-
.../execution/operator/LastQueryOperatorTest.java | 10 +-
.../operator/LastQueryTreeSortOperatorTest.java | 10 +-
.../execution/operator/OperatorMemoryTest.java | 18 +-
.../operator/RawDataAggregationOperatorTest.java | 6 +-
.../SeriesAggregationScanOperatorTest.java | 68 +--
.../SlidingWindowAggregationOperatorTest.java | 9 +-
.../operator/UpdateLastCacheOperatorTest.java | 10 +-
.../plan/relational/analyzer/AggregationTest.java | 171 +++++--
.../plan/relational/analyzer/JoinTest.java | 10 +-
.../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 | 33 +-
.../assembly/resources/sbin/destroy-datanode.bat | 12 +-
.../assembly/resources/sbin/destroy-datanode.sh | 4 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 6 +-
.../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 | 144 +++++-
.../src/main/thrift/confignode.thrift | 7 +
.../src/main/thrift/datanode.thrift | 15 +-
pom.xml | 89 +++-
src/main/groovy/checkDependencies.groovy | 60 +++
src/main/xslt/sbom-filter.xsl | 41 ++
300 files changed, 7694 insertions(+), 3422 deletions(-)
create mode 100644 .github/workflows/dependency-check.yml
create mode 100644 dependencies.json
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/pool/IoTDBInsertTableSessionPoolIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{pipe/task/ShowPipePlanV2.java
=> ConfigPhysicalReadPlan.java} (76%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java}
(70%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{partition/GetOrCreateSchemaPartitionPlan.java
=> table/FetchTablePlan.java} (63%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{
=> write}/auth/AuthorPlan.java (67%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlanV1.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/FetchTableResp.java
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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/IAggregator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/{Aggregator.java
=> TreeAggregator.java} (97%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{InnerJoinOperator.java
=> TableFullOuterJoinOperator.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{InnerJoinOperator.java
=> TableInnerJoinOperator.java} (87%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/Accumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AccumulatorFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AggregationOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AvgAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/CountAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableAggregator.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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
=> queryengine/plan/relational/sql/ast/PipeStatement.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{subscription/event/pipe/SubscriptionPipeTabletBatchEvents.java
=> queryengine/plan/relational/sql/ast/ShowAINodes.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{subscription/event/pipe/SubscriptionPipeEmptyEvent.java
=> queryengine/plan/relational/sql/ast/ShowPipePlugins.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/CoalesceColumnTransformer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/AggregationMergeSortOperatorTest.java
create mode 100644 src/main/groovy/checkDependencies.groovy
create mode 100644 src/main/xslt/sbom-filter.xsl
