You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/03/14 01:52:02 UTC
[iotdb] 07/11: Merge remote-tracking branch 'origin/master' into lmh/MLSQL
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch lmh/MLSQL
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit aa27beab1e29e8f601d761b76bc4f3a3378bb1fc
Merge: 461bdc360f 4ae7b3ab89
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Tue Feb 28 15:04:45 2023 +0800
Merge remote-tracking branch 'origin/master' into lmh/MLSQL
.../java/org/apache/iotdb/cli/AbstractCli.java | 8 +
.../confignode/client/DataNodeRequestType.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 3 +
.../confignode/conf/ConfigNodeDescriptor.java | 3 +-
.../consensus/request/ConfigPhysicalPlan.java | 24 ++
.../consensus/request/ConfigPhysicalPlanType.java | 10 +-
.../model/ShowModelPlan.java} | 58 ++-
.../request/read/model/ShowTrailPlan.java | 97 +++++
.../request/write/datanode/UpdateDataNodePlan.java | 32 +-
.../CreateModelPlan.java} | 47 ++-
.../DropModelPlan.java} | 50 ++-
.../request/write/model/UpdateModelInfoPlan.java | 98 +++++
.../request/write/model/UpdateModelStatePlan.java | 105 +++++
.../consensus/response/ModelTableResp.java | 55 +++
.../consensus/response/TrailTableResp.java | 55 +++
.../confignode/manager/ClusterSchemaManager.java | 50 ++-
.../iotdb/confignode/manager/ConfigManager.java | 86 +++-
.../apache/iotdb/confignode/manager/IManager.java | 35 +-
.../iotdb/confignode/manager/ModelManager.java | 158 +++++++
.../iotdb/confignode/manager/ProcedureManager.java | 30 ++
.../manager/consensus/ConsensusManager.java | 3 +
.../manager/node/ClusterNodeStartUtils.java | 88 ++--
.../iotdb/confignode/manager/node/NodeManager.java | 55 +--
.../manager/partition/PartitionManager.java | 4 +
.../iotdb/confignode/persistence/ModelInfo.java | 214 ++++++++++
.../persistence/executor/ConfigPlanExecutor.java | 27 +-
.../confignode/persistence/node/NodeInfo.java | 6 +-
.../persistence/partition/PartitionInfo.java | 26 +-
.../procedure/impl/model/CreateModelProcedure.java | 224 ++++++++++
.../procedure/impl/model/DropModelProcedure.java | 240 +++++++++++
.../procedure/state/model/CreateModelState.java | 18 +-
.../procedure/state/model/DropModelState.java | 20 +-
.../procedure/store/ProcedureFactory.java | 8 +
.../confignode/procedure/store/ProcedureType.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 4 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 2 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 39 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +-
.../iotdb/consensus/config/ConsensusConfig.java | 15 +
.../iotdb/consensus/ratis/RatisConsensus.java | 13 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 8 +-
.../ratis/metrics/MetricRegistryManager.java | 13 +-
.../consensus/ratis/metrics/RatisMetricSet.java | 10 +
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 2 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 2 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 2 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 +
.../iotdb/consensus/simple/RecoveryTest.java | 2 +
...pache-IoTDB-Performance-Overview-Dashboard.json | 363 ++++++++++++----
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 233 +++++------
docs/UserGuide/Query-Data/Group-By.md | 128 +++---
docs/UserGuide/Reference/Common-Config-Manual.md | 9 -
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 239 +++++------
docs/zh/UserGuide/Query-Data/Group-By.md | 128 +++---
.../zh/UserGuide/Reference/Common-Config-Manual.md | 9 -
grafana-plugin/yarn.lock | 12 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 8 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 6 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 42 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 65 +--
.../iotdb/it/env/cluster/MppCommonConfig.java | 6 -
.../it/env/cluster/MppSharedCommonConfig.java | 7 -
.../iotdb/it/env/remote/RemoteCommonConfig.java | 5 -
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 7 +-
.../it/cluster/IoTDBClusterRestartIT.java | 117 ++----
.../confignode/it/utils/ConfigNodeTestUtils.java | 27 +-
.../db/it/groupby/IoTDBGroupByConditionIT.java | 11 +
.../apache/iotdb/db/it/path/IoTDBFullPathIT.java | 82 ++++
.../iotdb/db/it/{ => path}/IoTDBQuotedPathIT.java | 2 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 9 -
.../db/integration/IoTDBQueryMemoryControlIT.java | 277 -------------
.../db/integration/env/StandaloneEnvConfig.java | 7 -
.../apache/iotdb/metrics/config/MetricConfig.java | 42 +-
.../reporter/prometheus/PrometheusTextWriter.java | 11 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 8 +-
.../org/apache/iotdb/metrics/utils/NodeType.java | 17 +-
.../iotdb/metrics/config/MetricConfigTest.java | 4 +-
node-commons/pom.xml | 5 +
.../resources/conf/iotdb-common.properties | 5 -
.../apache/iotdb/commons/conf/CommonConfig.java | 20 +
.../iotdb/commons/conf/CommonDescriptor.java | 14 +
.../iotdb/commons/model/ModelHyperparameter.java | 71 ++++
.../iotdb/commons/model/ModelInformation.java | 229 ++++++++++
.../org/apache/iotdb/commons/model/ModelTable.java | 91 ++++
.../iotdb/commons/model/TrailInformation.java | 101 +++++
.../model/exception/ModelManagementException.java | 15 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 30 ++
.../resources/conf/iotdb-datanode.properties | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 4 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 24 +-
.../org/apache/iotdb/db/client/MLNodeClient.java | 134 ++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 22 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 17 +-
.../db/engine/storagegroup/TsFileProcessor.java | 6 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 33 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../operator/source/ExchangeOperator.java | 23 +-
.../operator/window/SeriesWindowManager.java | 4 +-
.../plan/analyze/ColumnPaginationController.java | 34 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 75 ++--
.../db/mpp/plan/parser/StatementGenerator.java | 2 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 6 +-
.../iotdb/db/query/control/SessionManager.java | 55 ++-
.../java/org/apache/iotdb/db/service/DataNode.java | 9 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 2 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 2 +-
.../thrift/handler/BaseServerContextHandler.java | 4 +-
.../InternalServiceThriftHandlerMetrics.java | 6 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 9 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 461 ++++++++++++---------
.../file/UnsealedTsFileRecoverPerformer.java | 5 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 10 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 15 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +-
thrift-commons/src/main/thrift/common.thrift | 19 +
.../src/main/thrift/confignode.thrift | 63 ++-
thrift-mlnode/src/main/thrift/mlnode.thrift | 2 +-
thrift/src/main/thrift/datanode.thrift | 2 +-
127 files changed, 3954 insertions(+), 1701 deletions(-)