You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/14 11:49:25 UTC

[iotdb] branch xingtanzjr/device_group_id updated (daf15c0b15 -> 2e76062f57)

This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a change to branch xingtanzjr/device_group_id
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from daf15c0b15 comment assert in consensus test
     add 07a407be6f fix NPE when stop IoTDB and MLogTxtWriter parsing CreateAlignedTimeseriesPlan error (#5525)
     add 25dc043b17 get time partition interval from config node (#5523)
     add 627e479c3b [IOTDB-2779] TemporaryClient for ConfigNode to connect DataNode (#5530)
     add 74df66decc [IOTDB-2847] Implementation of PartitionFetcher (#5516)
     add a8c8acbc94 Generate header of result set: show timeseries/devices/sg (#5531)
     add 976d041b76 [IOTDB-2896] Fix warning of illegal seq compaction performer (#5534)
     add 12e3eb74a0 add some news for community/about (#5535)
     add 8c09a47c5d Implement basic SchemaFetcher (#5494)
     add 2e76062f57 Merge branch 'master' into xingtanzjr/device_group_id

No new revisions were added by this update.

Summary of changes:
 .../resources/conf/iotdb-confignode.properties     |  12 +-
 .../iotdb/confignode/cli/TemporaryClient.java      | 199 +++++++++++++
 .../iotdb/confignode/conf/ConfigNodeConf.java      |  11 +
 .../confignode/conf/ConfigNodeDescriptor.java      |   5 +
 .../consensus/response/DataPartitionDataSet.java   |  23 +-
 .../consensus/response/SchemaPartitionDataSet.java |  23 +-
 .../iotdb/confignode/manager/DataNodeManager.java  |   3 +
 .../iotdb/confignode/manager/RegionManager.java    |  29 +-
 .../persistence/DataNodeInfoPersistence.java       |  11 +
 .../iotdb/confignode/cli/TemporaryClientDemo.java  |  55 ++++
 docs/zh/Community/About.md                         |  66 ++++-
 .../iotdb/commons/cluster/DataNodeLocation.java    |   4 +
 .../iotdb/commons/partition/DataPartition.java     |   2 +-
 .../iotdb/commons/partition/RegionReplicaSet.java  |  38 +++
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |   3 +-
 .../statemachine/SchemaRegionStateMachine.java     |   5 +-
 .../exception/sql/StatementAnalyzeException.java   |  13 +-
 .../iotdb/db/metadata/logfile/MLogTxtWriter.java   |  11 +-
 .../db/metadata/schemaregion/SchemaRegion.java     |   3 +-
 .../iotdb/db/mpp/common/header/HeaderConstant.java |  90 ++++++
 .../db/mpp/common/schematree/PathPatternNode.java  |  13 +
 .../db/mpp/common/schematree/PathPatternTree.java  |  55 +++-
 .../db/mpp/common/schematree/SchemaEntityNode.java |  24 ++
 .../mpp/common/schematree/SchemaInternalNode.java  |  17 ++
 .../common/schematree/SchemaMeasurementNode.java   |  22 +-
 .../iotdb/db/mpp/common/schematree/SchemaNode.java |   8 +-
 .../iotdb/db/mpp/common/schematree/SchemaTree.java | 116 +++++++-
 .../mpp/operator/schema/SchemaFetchOperator.java   | 129 ++++++++
 .../apache/iotdb/db/mpp/sql/analyze/Analyzer.java  | 326 +++++++++++----------
 .../mpp/sql/analyze/ClusterPartitionFetcher.java   | 210 ++++++++++++-
 .../db/mpp/sql/analyze/ClusterSchemaFetcher.java   |  65 +++-
 .../mpp/sql/analyze/FakePartitionFetcherImpl.java  |  30 +-
 .../db/mpp/sql/analyze/IPartitionFetcher.java      |  16 +-
 .../sql/analyze/StandalonePartitionFetcher.java    |  23 +-
 .../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java |  12 +
 .../db/mpp/sql/planner/DistributionPlanner.java    |  22 +-
 .../db/mpp/sql/planner/LocalExecutionPlanner.java  |  22 +-
 .../iotdb/db/mpp/sql/planner/LogicalPlanner.java   |  16 +-
 .../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java |  20 +-
 .../db/mpp/sql/planner/plan/node/PlanNodeType.java |   6 +-
 .../db/mpp/sql/planner/plan/node/PlanVisitor.java  |  13 +-
 .../{ShowDevicesNode.java => SchemaFetchNode.java} |  45 ++-
 .../plan/node/metedata/read/SchemaMergeNode.java   |   2 +-
 .../plan/node/metedata/read/SchemaScanNode.java    |  11 +-
 .../db/mpp/sql/statement/StatementVisitor.java     |  10 +
 .../db/mpp/sql/statement/crud/QueryStatement.java  |   4 +-
 ...cesStatement.java => SchemaFetchStatement.java} |  38 ++-
 ...atement.java => ShowStorageGroupStatement.java} |  22 +-
 .../java/org/apache/iotdb/db/service/DataNode.java |   8 +
 .../apache/iotdb/db/service/IoTDBShutdownHook.java |   6 +-
 .../thrift/impl/DataNodeManagementServiceImpl.java |  14 +-
 .../{ => schematree}/PathPatternTreeTest.java      |  25 +-
 .../common/{ => schematree}/SchemaTreeTest.java    |  93 +++++-
 .../operator/schema/SchemaFetchOperatorTest.java   | 149 ++++++++++
 .../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java  |   2 +
 .../src/main/thrift/confignode.thrift              |   7 +-
 56 files changed, 1807 insertions(+), 400 deletions(-)
 create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
 create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/cli/TemporaryClientDemo.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/HeaderConstant.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperator.java
 copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{ShowDevicesNode.java => SchemaFetchNode.java} (55%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowDevicesStatement.java => SchemaFetchStatement.java} (56%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowDevicesStatement.java => ShowStorageGroupStatement.java} (71%)
 rename server/src/test/java/org/apache/iotdb/db/mpp/common/{ => schematree}/PathPatternTreeTest.java (89%)
 rename server/src/test/java/org/apache/iotdb/db/mpp/common/{ => schematree}/SchemaTreeTest.java (75%)
 create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperatorTest.java