This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/selectInto
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from de41d7c81c finish sql parser for SELECT INTO statement
add 6f10996b8c fix NoSuchFileException when taking snapshot (#7251)
add 35541f457a Add if to avoid assertTrue error (#7271)
add d192c1783c [IOTDB-4327] Make buffer size configurable (#7231)
add b71569a4a6 [IOTDB-4270] Support parallel transport for each pipe
(#7187)
add 98577b07b1 Delete information about rpc_port in UserGuide (#7279)
add b692bb70ab [IOTDB-3988][IOTDB-3733] Fix reload problem of metric
module, and refactor metric module. (#7239)
add ecee938113 [IOTDB-4326] Implementation of Create Trigger on DataNode
(#7257)
add 17330dba16 Delete information about rpc_port about README (#7282)
add bdd7ca8684 [IOTDB-4277] [IOTDB-4269] Optimize TypeProvider & bug fix
(#7266)
add 7ba099a074 [IOTDB-4384] Add influxdb and rest modules to the pom file
of the example module and rename inflxudb-protocol-example to
influxdb-protocol-example (#7288)
add 74fb350809 Update 0.14.0-preview2 download address (#7291)
new cf7d9cdee4 Merge remote-tracking branch 'origin/master' into
lmh/selectInto
new 55118b8b06 fix sql parser
The 2 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:
README.md | 8 +-
README_ZH.md | 8 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 1 +
.../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 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 73 +++--
.../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 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 20 +-
.../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 ++-
.../tsfile/common/constant/TsFileConstant.java | 4 +
179 files changed, 4508 insertions(+), 2049 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/NodeInfoMetrics.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceHandlerMetrics.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceMetrics.java
rename example/{inflxudb-protocol-example =>
influxdb-protocol-example}/pom.xml (94%)
rename example/{inflxudb-protocol-example =>
influxdb-protocol-example}/src/main/java/org/apache/iotdb/influxdb/InfluxDBExample.java
(100%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{predefined =>
metricsets}/IMetricSet.java (66%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/PredefinedMetric.java (94%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmClassLoaderMetrics.java (72%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmCompileMetrics.java (69%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmGcMetrics.java (79%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmMemoryMetrics.java (63%)
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmMetrics.java
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmThreadMetrics.java (68%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{ =>
metricsets}/predefined/jvm/JvmUtils.java (96%)
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/logback/LogbackMetrics.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/logback/MetricsTurboFilter.java
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmMetrics.java
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/logback/LogbackMetrics.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/trigger/exception/{TriggerRegistrationException.java
=> TriggerJarToLargeException.java} (82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/trigger/exception/{TriggerRegistrationException.java
=> TriggerManagementException.java} (82%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/trigger/service/{TriggerRegistrationService.java
=> TriggerExecutableManager.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCacheMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCacheMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManagerMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegionMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorInfoMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCacheMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaStatisticsManagerMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/NodeRef.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeServiceMetrics.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{MPPDataExchangeServiceThriftHandler.java
=> MppDataExchangeServiceThriftHandlerMetrics.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ExpressionTypeAnalyzer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/SubPlanTypeExtractor.java
rename
node-commons/src/main/java/org/apache/iotdb/commons/trigger/exception/TriggerRegistrationException.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/SimplePlanVisitor.java
(73%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/pool/RawQueryReadTaskPoolManagerMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/RPCServiceMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/handler/InternalServiceThriftHandlerMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/handler/RPCServiceThriftHandlerMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/trigger/executor/TriggerExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/trigger/service/TriggerManagementService.java
