This is an automated email from the ASF dual-hosted git repository. FrankChen021 pushed a commit to branch codex/native-sys-servers in repository https://gitbox.apache.org/repos/asf/druid.git
commit 2b4df23760a439f7f6d3e3de837aea4d5edabb53 Author: Frank Chen <[email protected]> AuthorDate: Wed Sep 2 18:31:34 2026 +0800 refactor(sql): reuse servers table row signature --- .../main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java | 4 +--- .../java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java | 3 ++- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java index db988d5ac36..2ce42a5f5cf 100644 --- a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java +++ b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java @@ -199,8 +199,6 @@ public class SystemSchema extends AbstractTableSchema } ); - static final RowSignature SERVERS_SIGNATURE = ServersTableDescriptor.ROW_SIGNATURE; - static final RowSignature SERVER_SEGMENTS_SIGNATURE = RowSignature .builder() .add("server", ColumnType.STRING) @@ -671,7 +669,7 @@ public class SystemSchema extends AbstractTableSchema @Override public RelDataType getRowType(RelDataTypeFactory typeFactory) { - return RowSignatures.toRelDataType(SERVERS_SIGNATURE, typeFactory); + return RowSignatures.toRelDataType(ServersTableDescriptor.ROW_SIGNATURE, typeFactory); } @Override diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index e7839a8bd3b..47283ab9156 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -107,6 +107,7 @@ import org.apache.druid.server.security.Authorizer; import org.apache.druid.server.security.AuthorizerMapper; import org.apache.druid.server.security.NoopEscalator; import org.apache.druid.server.security.ResourceType; +import org.apache.druid.server.system.table.ServersTableDescriptor; import org.apache.druid.server.system.table.TaskTableDescriptor; import org.apache.druid.sql.calcite.planner.PlannerConfig; import org.apache.druid.sql.calcite.run.SqlEngine; @@ -1283,7 +1284,7 @@ public class SystemSchemaTest extends CalciteTestBase } // Verify value types. - verifyTypes(rows, SystemSchema.SERVERS_SIGNATURE); + verifyTypes(rows, ServersTableDescriptor.ROW_SIGNATURE); } private DruidServer mockDataServer(String name, long currentSize, long maxSize, String tier) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
