You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2024/06/13 06:28:05 UTC
(iotdb) 01/03: Merge branch 'ty/TableModelGrammar' of github.com:apache/iotdb into ty/TableModelGrammar
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/TableModelGrammar_DistributePlan
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8f4d9bbe7aa5872b62afec0b40a5c59e5f78061d
Merge: e9583f870c9 50d8708f2ec
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Wed Jun 12 15:43:49 2024 +0800
Merge branch 'ty/TableModelGrammar' of github.com:apache/iotdb into ty/TableModelGrammar
distribution/src/assembly/all.xml | 9 +
distribution/src/assembly/confignode.xml | 9 +
distribution/src/assembly/datanode.xml | 9 +
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 89 +++++++
.../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 5 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 15 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 3 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 3 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQuery2IT.java | 216 ++++++++++++++++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 34 ++-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 8 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 4 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 4 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../assembly/resources/sbin/stop-confignode.bat | 19 +-
.../confignode/client/ConfigNodeRequestType.java | 4 +-
.../confignode/client/DataNodeRequestType.java | 2 +
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/sync/SyncConfigNodeClientPool.java | 3 +
.../client/sync/SyncDataNodeClientPool.java | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 52 ++++
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/node/NodeManager.java | 107 +++++++-
.../manager/partition/PartitionManager.java | 2 +-
.../persistence/pipe/PipePluginInfo.java | 39 +--
.../procedure/env/ConfigNodeProcedureEnv.java | 22 +-
.../procedure/env/RegionMaintainHandler.java | 78 +++---
.../impl/sync/AuthOperationProcedure.java | 11 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +
.../src/assembly/resources/sbin/stop-datanode.bat | 24 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 14 ++
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 71 +++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 22 ++
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../db/queryengine/plan/analyze/IAnalysis.java | 16 ++
.../plan/analyze/LoadTsfileAnalyzer.java | 8 +
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 87 +++++--
.../config/executor/IConfigTaskExecutor.java | 3 +
.../execution/config/sys/SetConfigurationTask.java | 45 ++++
.../db/queryengine/plan/parser/ASTVisitor.java | 20 ++
.../distribution/WriteFragmentParallelPlanner.java | 11 +-
.../plan/planner/plan/node/WritePlanNode.java | 4 +-
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../planner/plan/node/load/LoadTsFileNode.java | 9 +-
.../plan/node/load/LoadTsFilePieceNode.java | 4 +-
.../node/metedata/write/ActivateTemplateNode.java | 4 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 4 +-
.../metedata/write/BatchActivateTemplateNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 4 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 4 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 4 +-
.../write/InternalBatchActivateTemplateNode.java | 4 +-
.../write/InternalCreateMultiTimeSeriesNode.java | 4 +-
.../write/InternalCreateTimeSeriesNode.java | 4 +-
.../metedata/write/view/CreateLogicalViewNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedWritePlanNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 5 +-
.../plan/node/write/InsertMultiTabletsNode.java | 4 +-
.../planner/plan/node/write/InsertRowNode.java | 4 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../plan/relational/analyzer/Analysis.java | 28 +++
.../metadata/ITableDeviceSchemaValidation.java | 66 +++++
.../plan/relational/metadata/Metadata.java | 30 +++
.../relational/metadata/TableMetadataImpl.java | 13 +
.../fetcher/cache/TableDeviceCacheEntry.java | 55 +++++
.../metadata/fetcher/cache/TableDeviceId.java | 62 +++++
.../fetcher/cache/TableDeviceSchemaCache.java | 86 +++++++
.../relational/metadata/fetcher/cache/TableId.java | 67 +++++
.../distribute/TableDistributionPlanner.java | 5 +-
...or.java => TableModelQueryFragmentPlanner.java} | 7 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
.../statement/sys/SetConfigurationStatement.java | 72 ++++++
.../dag/intermediate/MultiInputLayer.java | 5 +-
.../SingleInputMultiReferenceLayer.java | 12 +-
.../SingleInputSingleReferenceLayer.java | 12 +-
.../iotdb/db/storageengine/StorageEngine.java | 42 ++++
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../plan/relational/analyzer/TestMatadata.java | 14 ++
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 100 ++++++++
iotdb-core/node-commons/pom.xml | 76 ++++++
.../resources/conf/generate_properties.bat | 64 +++++
.../assembly/resources/conf/generate_properties.sh | 59 +++++
.../resources/conf/iotdb-system.properties | 2 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 +-
.../commons/conf/ConfigFileAutoUpdateTool.java | 126 ----------
.../iotdb/commons/conf/ConfigurationFileUtils.java | 275 +++++++++++++++++++++
.../commons/partition/SeriesPartitionTable.java | 28 +--
.../pipe/connector/protocol/IoTDBConnector.java | 28 ++-
.../apache/iotdb/commons/schema/MemUsageUtil.java | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 18 +-
.../src/main/thrift/confignode.thrift | 6 +
.../thrift-datanode/src/main/thrift/client.thrift | 4 +
.../src/main/thrift/datanode.thrift | 4 +
105 files changed, 2259 insertions(+), 383 deletions(-)