This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/selectInto in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cf7d9cdee4e459bfcbf6d9d0ba9468b1b5eedb3f Merge: de41d7c81c 74fb350809 Author: Minghui Liu <[email protected]> AuthorDate: Tue Sep 13 10:33:01 2022 +0800 Merge remote-tracking branch 'origin/master' into lmh/selectInto README.md | 8 +- README_ZH.md | 8 +- .../resources/conf/iotdb-confignode.properties | 10 +- .../iotdb/confignode/conf/ConfigNodeConfig.java | 13 +- .../confignode/conf/ConfigNodeDescriptor.java | 9 + .../consensus/response/DataNodeRegisterResp.java | 7 + .../iotdb/confignode/manager/NodeManager.java | 13 +- .../iotdb/confignode/manager/PartitionManager.java | 4 +- .../iotdb/confignode/manager/load/LoadManager.java | 6 +- .../manager/load/LoadManagerMetrics.java | 288 ++++++++++--------- .../iotdb/confignode/persistence/NodeInfo.java | 30 -- .../persistence/metric/NodeInfoMetrics.java | 95 +++++++ .../persistence/metric/PartitionInfoMetrics.java | 198 +++++++++++++ .../persistence/partition/PartitionInfo.java | 47 +--- .../partition/StorageGroupPartitionTable.java | 58 +--- .../iotdb/confignode/service/ConfigNode.java | 4 - .../service/thrift/ConfigNodeRPCService.java | 13 +- .../thrift/ConfigNodeRPCServiceHandler.java | 28 +- .../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 69 +++++ .../thrift/ConfigNodeRPCServiceMetrics.java | 70 +++++ .../apache/iotdb/consensus/config/RatisConfig.java | 73 +++++ .../org/apache/iotdb/consensus/ratis/Utils.java | 7 + docs/Download/README.md | 14 +- docs/UserGuide/QuickStart/QuickStart.md | 10 +- docs/zh/Download/README.md | 14 +- docs/zh/UserGuide/QuickStart/QuickStart.md | 8 +- .../pom.xml | 4 +- .../org/apache/iotdb/influxdb/InfluxDBExample.java | 0 example/pom.xml | 2 + .../main/java/org/apache/iotdb/HttpExample.java | 7 +- .../main/java/org/apache/iotdb/HttpsExample.java | 16 +- .../src/main/java/org/apache/iotdb/SSLClient.java | 65 +++-- .../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 16 ++ .../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +- .../sync/IoTDBSyncReceiverLoaderIT.java | 2 +- .../reporter/DropwizardPrometheusReporter.java | 4 +- .../iotdb/metrics/AbstractMetricService.java | 65 ++++- .../iotdb/metrics/DoNothingMetricService.java | 2 +- .../apache/iotdb/metrics/config/MetricConfig.java | 4 +- .../{predefined => metricsets}/IMetricSet.java | 19 +- .../predefined/PredefinedMetric.java | 2 +- .../predefined/jvm/JvmClassLoaderMetrics.java | 20 +- .../predefined/jvm/JvmCompileMetrics.java | 20 +- .../predefined/jvm/JvmGcMetrics.java | 117 +++++--- .../predefined/jvm/JvmMemoryMetrics.java | 55 +++- .../metricsets/predefined/jvm/JvmMetrics.java | 52 ++++ .../predefined/jvm/JvmThreadMetrics.java | 43 ++- .../{ => metricsets}/predefined/jvm/JvmUtils.java | 2 +- .../predefined/logback/LogbackMetrics.java | 104 +++++++ .../predefined/logback/MetricsTurboFilter.java | 98 +++++++ .../iotdb/metrics/predefined/jvm/JvmMetrics.java | 49 ---- .../metrics/predefined/logback/LogbackMetrics.java | 181 ------------ .../reporter/MicrometerPrometheusReporter.java | 5 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 4 +- .../commons/executable/ExecutableManager.java | 54 ++++ .../org/apache/iotdb/commons/path/PartialPath.java | 8 + .../apache/iotdb/commons/service/ServiceType.java | 1 + .../apache/iotdb/commons/sync/SyncPathUtil.java | 18 ++ .../iotdb/commons/trigger/TriggerInformation.java | 12 + .../apache/iotdb/commons/trigger/TriggerTable.java | 12 + ...eption.java => TriggerJarToLargeException.java} | 6 +- ...eption.java => TriggerManagementException.java} | 6 +- ...nService.java => TriggerExecutableManager.java} | 60 ++-- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 37 ++- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 + .../db/consensus/DataRegionConsensusImpl.java | 5 + .../apache/iotdb/db/engine/StorageEngineV2.java | 2 +- .../apache/iotdb/db/engine/cache/ChunkCache.java | 16 +- .../iotdb/db/engine/cache/ChunkCacheMetrics.java | 67 +++++ .../db/engine/cache/TimeSeriesMetadataCache.java | 35 +-- .../cache/TimeSeriesMetadataCacheMetrics.java | 77 +++++ .../apache/iotdb/db/engine/flush/FlushManager.java | 31 +-- .../iotdb/db/engine/flush/FlushManagerMBean.java | 2 + .../iotdb/db/engine/flush/FlushManagerMetrics.java | 90 ++++++ .../iotdb/db/engine/snapshot/SnapshotTaker.java | 3 + .../iotdb/db/engine/storagegroup/DataRegion.java | 16 +- .../db/engine/storagegroup/DataRegionMetrics.java | 73 +++++ .../engine/storagegroup/TsFileProcessorInfo.java | 32 +-- .../storagegroup/TsFileProcessorInfoMetrics.java | 74 +++++ .../db/exception/sync/PipeServerException.java | 2 +- .../db/metadata/cache/DataNodeSchemaCache.java | 16 +- .../metadata/cache/DataNodeSchemaCacheMetrics.java | 67 +++++ .../db/metadata/rescon/SchemaResourceManager.java | 4 +- .../metadata/rescon/SchemaStatisticsManager.java | 16 -- .../rescon/SchemaStatisticsManagerMetrics.java | 67 +++++ .../iotdb/db/mpp/common/MPPQueryContext.java | 7 + .../org/apache/iotdb/db/mpp/common/NodeRef.java | 61 ++++ .../execution/exchange/MPPDataExchangeService.java | 12 +- .../exchange/MPPDataExchangeServiceMetrics.java | 65 +++++ .../MPPDataExchangeServiceThriftHandler.java | 27 +- ...ppDataExchangeServiceThriftHandlerMetrics.java} | 51 ++-- .../db/mpp/execution/exchange/SinkHandle.java | 6 +- .../operator/process/TransformOperator.java | 11 +- .../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 31 ++- .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 144 ++++------ .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 5 +- .../db/mpp/plan/analyze/ExpressionAnalyzer.java | 118 ++------ .../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 310 +++++++++++++++++++++ .../mpp/plan/analyze/GroupByLevelController.java | 4 +- .../iotdb/db/mpp/plan/analyze/TypeProvider.java | 15 +- .../config/executor/ClusterConfigTaskExecutor.java | 39 ++- .../config/executor/IConfigTaskExecutor.java | 13 +- .../executor/StandaloneConfigTaskExecutor.java | 15 +- .../config/metadata/CreateTriggerTask.java | 27 +- .../iotdb/db/mpp/plan/expression/Expression.java | 27 +- .../binary/ArithmeticBinaryExpression.java | 25 +- .../plan/expression/binary/BinaryExpression.java | 8 +- .../expression/binary/CompareBinaryExpression.java | 54 +--- .../expression/binary/LogicBinaryExpression.java | 15 +- .../mpp/plan/expression/leaf/ConstantOperand.java | 7 - .../db/mpp/plan/expression/leaf/LeafOperand.java | 5 +- .../plan/expression/leaf/TimeSeriesOperand.java | 7 - .../mpp/plan/expression/leaf/TimestampOperand.java | 8 - .../plan/expression/multi/FunctionExpression.java | 44 +-- .../plan/expression/ternary/BetweenExpression.java | 20 +- .../plan/expression/ternary/TernaryExpression.java | 11 +- .../db/mpp/plan/expression/unary/InExpression.java | 18 +- .../plan/expression/unary/IsNullExpression.java | 18 +- .../mpp/plan/expression/unary/LikeExpression.java | 20 +- .../plan/expression/unary/LogicNotExpression.java | 20 +- .../plan/expression/unary/NegationExpression.java | 26 +- .../plan/expression/unary/RegularExpression.java | 20 +- .../mpp/plan/expression/unary/UnaryExpression.java | 7 +- .../visitor/ColumnTransformerVisitor.java | 69 ++--- .../plan/expression/visitor/ExpressionVisitor.java | 63 ++++- .../visitor/IntermediateLayerVisitor.java | 17 +- .../db/mpp/plan/planner/LogicalPlanBuilder.java | 85 +++++- .../db/mpp/plan/planner/LogicalPlanVisitor.java | 44 ++- .../db/mpp/plan/planner/OperatorTreeGenerator.java | 31 ++- .../db/mpp/plan/planner/SubPlanTypeExtractor.java | 110 ++++++++ .../SimpleFragmentParallelPlanner.java | 5 +- .../plan/planner/distribution/SourceRewriter.java | 18 +- .../db/mpp/plan/planner/plan/PlanFragment.java | 9 +- .../plan/planner/plan/node/SimplePlanVisitor.java | 16 +- .../dag/builder/EvaluationDAGBuilder.java | 16 +- .../db/query/pool/RawQueryReadTaskPoolManager.java | 32 +-- .../pool/RawQueryReadTaskPoolManagerMetrics.java | 92 ++++++ .../java/org/apache/iotdb/db/service/DataNode.java | 26 +- .../db/service/DataNodeInternalRPCService.java | 12 +- .../service/DataNodeInternalRPCServiceMetrics.java | 72 +++++ .../java/org/apache/iotdb/db/service/IoTDB.java | 5 +- .../java/org/apache/iotdb/db/service/NewIoTDB.java | 5 +- .../org/apache/iotdb/db/service/RPCService.java | 13 +- .../apache/iotdb/db/service/RPCServiceMetrics.java | 71 +++++ .../iotdb/db/service/metrics/MetricService.java | 31 +-- .../db/service/metrics/predefined/FileMetrics.java | 69 +++-- .../service/metrics/predefined/ProcessMetrics.java | 80 ++++-- .../service/metrics/predefined/SystemMetrics.java | 116 +++++--- .../handler/InternalServiceThriftHandler.java | 22 +- .../InternalServiceThriftHandlerMetrics.java | 68 +++++ .../thrift/handler/RPCServiceThriftHandler.java | 19 +- .../handler/RPCServiceThriftHandlerMetrics.java | 65 +++++ .../impl/DataNodeInternalRPCServiceImpl.java | 39 ++- .../java/org/apache/iotdb/db/sync/SyncService.java | 101 ++----- .../iotdb/db/sync/pipedata/TsFilePipeData.java | 6 +- .../sync/pipedata/queue/BufferedPipeDataQueue.java | 1 + .../db/sync/pipedata/queue/PipeDataQueue.java | 2 + .../iotdb/db/sync/receiver/load/TsFileLoader.java | 5 +- .../db/sync/sender/manager/LocalSyncManager.java | 8 +- .../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 14 +- .../iotdb/db/sync/sender/pipe/TsFilePipe.java | 176 ++++++++---- .../db/sync/transport/client/IoTDBSyncClient.java | 21 +- .../db/sync/transport/client/SenderManager.java | 98 +++++-- .../sync/transport/client/SyncClientFactory.java | 14 +- .../db/sync/transport/server/ReceiverManager.java | 4 +- .../iotdb/db/trigger/executor/TriggerExecutor.java | 57 ++++ .../trigger/service/TriggerManagementService.java | 189 +++++++++++++ .../db/engine/snapshot/IoTDBSnapshotTest.java | 38 +++ .../apache/iotdb/db/metric/MetricServiceTest.java | 1 - .../mpp/plan/plan/distribution/LastQueryTest.java | 26 +- .../iotdb/db/sync/transport/SyncTransportTest.java | 11 +- .../src/main/thrift/confignode.thrift | 15 +- thrift/src/main/thrift/client.thrift | 1 + thrift/src/main/thrift/datanode.thrift | 41 ++- 174 files changed, 4431 insertions(+), 2017 deletions(-)
