You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/04/14 10:57:56 UTC
[iotdb] branch ty-mpp updated (89301508bb -> 489aab46c7)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 89301508bb fix DataNode start up bug
add 12e3eb74a0 add some news for community/about (#5535)
add 8c09a47c5d Implement basic SchemaFetcher (#5494)
add ed4c7ea7c0 resolve conflicts
add d1278f8507 [IOTDB-2863] Serialize and deserialize of insert node (#5517)
add 489aab46c7 Merge remote-tracking branch 'origin/master' into ty-mpp
No new revisions were added by this update.
Summary of changes:
docs/zh/Community/About.md | 66 ++-
.../statemachine/SchemaRegionStateMachine.java | 5 +-
.../exception/sql/StatementAnalyzeException.java | 13 +-
.../db/metadata/schemaregion/SchemaRegion.java | 3 +-
.../db/mpp/common/schematree/PathPatternNode.java | 13 +
.../db/mpp/common/schematree/PathPatternTree.java | 43 +-
.../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 | 129 +++++-
.../mpp/operator/schema/SchemaFetchOperator.java | 129 ++++++
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 486 ++++++++++-----------
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 29 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 65 ++-
.../db/mpp/sql/analyze/IPartitionFetcher.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/PlanNodeId.java | 16 +
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 22 +-
.../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 +-
.../plan/node/write/InsertMultiTabletsNode.java | 15 +
.../sql/planner/plan/node/write/InsertNode.java | 50 ++-
.../sql/planner/plan/node/write/InsertRowNode.java | 344 ++++++++++++++-
.../planner/plan/node/write/InsertRowsNode.java | 16 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 16 +
.../planner/plan/node/write/InsertTabletNode.java | 473 +++++++++++++++++++-
.../db/mpp/sql/statement/StatementVisitor.java | 5 +
.../sql/statement/crud/InsertTabletStatement.java | 2 +-
...cesStatement.java => SchemaFetchStatement.java} | 38 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 5 +-
.../{ => schematree}/PathPatternTreeTest.java | 25 +-
.../common/{ => schematree}/SchemaTreeTest.java | 93 +++-
.../operator/schema/SchemaFetchOperatorTest.java | 149 +++++++
.../plan/node/write/InsertRowNodeSerdeTest.java | 126 ++++++
.../plan/node/write/InsertTabletNodeSerdeTest.java | 94 ++++
41 files changed, 2299 insertions(+), 405 deletions(-)
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%)
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
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java