You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/08/03 08:05:34 UTC
[iotdb] branch enable_time_partition updated (597933e488 -> b277cceee3)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch enable_time_partition
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 597933e488 Fix test
add 55b5b17af2 [IOTDB-3983] Recover wal file's metadata (#6838)
add 2de0dd8731 fix template api in SessionPool for master (#6810)
add 5f118301f6 fix NullPointerException (#6852)
add 8e39a52e23 [IOTDB-3844] Clear up Non-Seed-ConfigNode register process (#6831)
add 1140cf2da6 Influxdb service adapts to distributed MPP framework and fixes some bugs in InfluxFunction and TagInfoRecord (#6828)
add df9c629453 Improve the performance of Raw Query Without ValueFilter for nonAligned (#6853)
add 47d4b06db3 Add the CPU load status, memory status, disk status in DashBoard (#6834)
add ef0e514ca6 [IOTDB-3955] Improved node information metrics to push more detailed node information, online and offline total and survival information of each node (#6801)
add c7b5eeb8cf [IOTDB-3814] Fix insert rows by sql with wrong data type NPE (#6859)
add 21c530abf7 [IOTDB-4007]Support multiple paths in privilege control (#6854)
add 73d5b80f34 [IOTDB-3847] Clear up interfaces in NodeManager(#6862)
add 32fefe24bd [IOTDB-3847] Clear up interfaces in NodeManager (#6862)
add 2d81290687 Merge branch 'master' of https://github.com/apache/iotdb into enable_time_partition
add b277cceee3 fix
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 12 +-
.../sync/confignode/SyncConfigNodeClientPool.java | 22 +-
.../consensus/request/auth/AuthorPlan.java | 25 +-
...eption.java => AddConsensusGroupException.java} | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 89 +---
.../apache/iotdb/confignode/manager/IManager.java | 5 +-
.../iotdb/confignode/manager/NodeManager.java | 113 +----
.../iotdb/confignode/manager/load/LoadManager.java | 215 +++++++++
.../iotdb/confignode/persistence/AuthorInfo.java | 68 ++-
.../iotdb/confignode/persistence/NodeInfo.java | 10 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 20 +-
.../iotdb/confignode/service/ConfigNode.java | 19 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 20 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 121 ++++-
.../confignode/persistence/AuthorInfoTest.java | 305 +++++++++++-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 74 ++-
docker/src/main/Dockerfile-single-influxdb | 4 +-
.../Administration-Management/Administration.md | 38 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 8 +-
.../Administration-Management/Administration.md | 38 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 20 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 275 ++++++++++-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 289 +++++++++++-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 12 +
.../micrometer/MicrometerMetricManagerTest.java | 11 +
.../apache/iotdb/commons/cluster/NodeStatus.java | 4 +
.../commons/utils/BasicStructureSerDeUtil.java | 31 ++
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 9 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 3 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 73 ++-
.../operator/process/DeviceMergeOperator.java | 2 +-
.../RowBasedTimeJoinOperator.java} | 62 +--
.../process/{ => join}/TimeJoinOperator.java | 7 +-
.../{ => join}/merge/AscTimeComparator.java | 2 +-
.../process/{ => join}/merge/ColumnMerger.java | 24 +-
.../{ => join}/merge/DescTimeComparator.java | 2 +-
.../{ => join}/merge/MultiColumnMerger.java | 56 ++-
.../merge/NonOverlappedMultiColumnMerger.java | 25 +-
.../{ => join}/merge/SingleColumnMerger.java | 44 +-
.../process/{ => join}/merge/TimeComparator.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 14 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 48 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 19 +-
.../plan/node/write/InsertMultiTabletsNode.java | 3 +
.../planner/plan/node/write/InsertRowNode.java | 14 +-
.../planner/plan/node/write/InsertRowsNode.java | 3 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 3 +
.../db/mpp/plan/statement/sys/AuthorStatement.java | 12 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 40 +-
.../function/aggregator/InfluxMeanFunction.java | 4 +-
.../function/selector/InfluxFirstFunction.java | 5 +-
.../function/selector/InfluxLastFunction.java | 5 +-
.../influxdb/handler/AbstractQueryHandler.java | 511 +++++++++++++++++++++
.../protocol/influxdb/handler/NewQueryHandler.java | 200 ++++++++
.../db/protocol/influxdb/handler/QueryHandler.java | 468 +------------------
.../influxdb/meta/AbstractInfluxDBMetaManager.java | 114 +++++
.../influxdb/meta/InfluxDBMetaManager.java | 96 +---
.../influxdb/meta/NewInfluxDBMetaManager.java | 129 ++++++
.../db/protocol/influxdb/meta/TagInfoRecords.java | 28 +-
.../influxdb/util/InfluxReqAndRespUtils.java | 55 +++
.../protocol/influxdb/util/QueryResultUtils.java | 153 ++++++
.../db/protocol/influxdb/util/StringUtils.java | 11 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 74 ++-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 14 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 54 ++-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 44 +-
.../iotdb/db/service/InfluxDBRPCService.java | 26 +-
.../handler/InfluxDBServiceThriftHandler.java | 10 +-
...ndler.java => IInfluxDBServiceWithHandler.java} | 4 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 20 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 128 ++++++
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 3 +-
.../iotdb/db/wal/recover/WALRecoverWriter.java | 26 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 6 +-
.../operator/AlignedSeriesScanOperatorTest.java | 8 +-
.../operator/DeviceMergeOperatorTest.java | 2 +-
.../mpp/execution/operator/LimitOperatorTest.java | 6 +-
.../execution/operator/MultiColumnMergerTest.java | 2 +-
.../NonOverlappedMultiColumnMergerTest.java | 4 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 6 +-
.../operator/RawDataAggregationOperatorTest.java | 6 +-
.../execution/operator/SingleColumnMergerTest.java | 6 +-
.../execution/operator/TimeJoinOperatorTest.java | 8 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 2 +-
.../iotdb/db/wal/recover/WALRecoverWriterTest.java | 198 ++++++++
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +
.../src/main/thrift/confignode.thrift | 12 +-
88 files changed, 3608 insertions(+), 1170 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/exception/{AddPeerException.java => AddConsensusGroupException.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{TimeJoinOperator.java => join/RowBasedTimeJoinOperator.java} (85%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/TimeJoinOperator.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/AscTimeComparator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/ColumnMerger.java (70%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/DescTimeComparator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/MultiColumnMerger.java (63%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/NonOverlappedMultiColumnMerger.java (82%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/SingleColumnMerger.java (74%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ => join}/merge/TimeComparator.java (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/AbstractQueryHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/NewQueryHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/AbstractInfluxDBMetaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/InfluxReqAndRespUtils.java
copy server/src/main/java/org/apache/iotdb/db/service/thrift/impl/{IClientRPCServiceWithHandler.java => IInfluxDBServiceWithHandler.java} (85%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/WALRecoverWriterTest.java