This is an automated email from the ASF dual-hosted git repository. zyk pushed a commit to branch table-model-debug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7a1728ce6c907dfda3a46055e6c205e608fedbb3 Author: MarcosZyk <[email protected]> AuthorDate: Thu Apr 18 10:17:17 2024 +0800 implement getTableSchema --- .../relational/analyzer/schema/TableModelSchemaFetcher.java | 12 ++++++++++++ .../plan/relational/metadata/TableMetadataImpl.java | 8 +++++++- 2 files changed, 19 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/TableModelSchemaFetcher.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/TableModelSchemaFetcher.java index 7bec6837bfa..ca4c7fee853 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/TableModelSchemaFetcher.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/schema/TableModelSchemaFetcher.java @@ -29,9 +29,13 @@ import org.apache.iotdb.db.queryengine.plan.analyze.ClusterPartitionFetcher; import org.apache.iotdb.db.queryengine.plan.analyze.QueryType; import org.apache.iotdb.db.queryengine.plan.analyze.schema.ClusterSchemaFetcher; import org.apache.iotdb.db.queryengine.plan.execution.ExecutionResult; +import org.apache.iotdb.db.queryengine.plan.relational.metadata.DeviceEntry; import org.apache.iotdb.db.queryengine.plan.statement.internal.CreateTableDeviceStatement; +import org.apache.iotdb.db.relational.sql.tree.Expression; import org.apache.iotdb.rpc.TSStatusCode; +import java.util.List; + public class TableModelSchemaFetcher { private final IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig(); @@ -75,4 +79,12 @@ public class TableModelSchemaFetcher { executionResult.status.getMessage(), executionResult.status.getCode())); } } + + public List<DeviceEntry> fetchDeviceSchema( + String database, + String table, + List<Expression> expressionList, + List<String> attributeColumns) { + return null; + } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java index a03f65fd8a3..a993523ba22 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java @@ -25,6 +25,7 @@ import org.apache.iotdb.commons.udf.builtin.BuiltinScalarFunction; import org.apache.iotdb.db.exception.metadata.table.TableNotExistsException; import org.apache.iotdb.db.exception.sql.SemanticException; import org.apache.iotdb.db.queryengine.common.SessionInfo; +import org.apache.iotdb.db.queryengine.plan.relational.analyzer.schema.TableModelSchemaFetcher; import org.apache.iotdb.db.queryengine.plan.relational.function.OperatorType; import org.apache.iotdb.db.queryengine.plan.relational.security.AccessControl; import org.apache.iotdb.db.queryengine.plan.relational.type.InternalTypeManager; @@ -255,7 +256,12 @@ public class TableMetadataImpl implements Metadata { QualifiedObjectName tableName, List<Expression> expressionList, List<String> attributeColumns) { - return null; + return TableModelSchemaFetcher.getInstance() + .fetchDeviceSchema( + tableName.getDatabaseName(), + tableName.getObjectName(), + expressionList, + attributeColumns); } public static boolean isTwoNumericType(List<? extends Type> argumentTypes) {
