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 2022/09/13 09:54:33 UTC
[iotdb] 01/02: Merge remote-tracking branch 'origin/master' into lmh/selectInto
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 <li...@foxmail.com>
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(-)