Skip to content

Commit

Permalink
Fix indentation
Browse files Browse the repository at this point in the history
  • Loading branch information
findepi committed Feb 9, 2022
1 parent 4df4c5e commit 06ba92e
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -281,13 +281,13 @@ public List<SchemaTableName> listTables(ConnectorSession session, Optional<Strin
listNamespaces(session, namespace)
.stream()
.flatMap(schema -> 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);

Expand Down

0 comments on commit 06ba92e

Please sign in to comment.