From 06ba92e6546ca6b3c23912075950518f78c7323f Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Mon, 31 Jan 2022 17:25:54 +0100 Subject: [PATCH] Fix indentation --- .../io/trino/plugin/iceberg/TrinoHiveCatalog.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java index 5a9376388581..6c99b6a436dd 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java @@ -281,13 +281,13 @@ public List listTables(ConnectorSession session, Optional Stream.concat( - // Get tables with parameter table_type set to "ICEBERG" or "iceberg". This is required because - // Trino uses lowercase value whereas Spark and Flink use uppercase. - // TODO: use one metastore call to pass both the filters: https://github.com/trinodb/trino/issues/7710 - metastore.getTablesWithParameter(schema, TABLE_TYPE_PROP, ICEBERG_TABLE_TYPE_VALUE.toLowerCase(Locale.ENGLISH)).stream() - .map(table -> new SchemaTableName(schema, table)), - metastore.getTablesWithParameter(schema, TABLE_TYPE_PROP, ICEBERG_TABLE_TYPE_VALUE.toUpperCase(Locale.ENGLISH)).stream() - .map(table -> new SchemaTableName(schema, table))) + // Get tables with parameter table_type set to "ICEBERG" or "iceberg". This is required because + // Trino uses lowercase value whereas Spark and Flink use uppercase. + // TODO: use one metastore call to pass both the filters: https://github.com/trinodb/trino/issues/7710 + metastore.getTablesWithParameter(schema, TABLE_TYPE_PROP, ICEBERG_TABLE_TYPE_VALUE.toLowerCase(Locale.ENGLISH)).stream() + .map(table -> new SchemaTableName(schema, table)), + metastore.getTablesWithParameter(schema, TABLE_TYPE_PROP, ICEBERG_TABLE_TYPE_VALUE.toUpperCase(Locale.ENGLISH)).stream() + .map(table -> new SchemaTableName(schema, table))) .distinct()) // distinct() to avoid duplicates for case-insensitive HMS backends .forEach(tablesListBuilder::add);