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