Remove system.iceberg_tables table function

We decided to add a system table instead.

This reverts commit 5ce80be.

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergModule.java

@@ -42,7 +42,6 @@
 import io.trino.plugin.iceberg.functions.IcebergFunctionProvider;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesFunctionProcessorProviderFactory;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesFunctionProvider;
-import io.trino.plugin.iceberg.functions.tables.IcebergTablesFunctionProvider;
 import io.trino.plugin.iceberg.procedure.AddFilesTableFromTableProcedure;
 import io.trino.plugin.iceberg.procedure.AddFilesTableProcedure;
 import io.trino.plugin.iceberg.procedure.DropExtendedStatsTableProcedure;
@@ -138,9 +137,7 @@ public void configure(Binder binder)
         tableProcedures.addBinding().toProvider(AddFilesTableProcedure.class).in(Scopes.SINGLETON);
         tableProcedures.addBinding().toProvider(AddFilesTableFromTableProcedure.class).in(Scopes.SINGLETON);
 
-        Multibinder<ConnectorTableFunction> tableFunctions = newSetBinder(binder, ConnectorTableFunction.class);
-        tableFunctions.addBinding().toProvider(TableChangesFunctionProvider.class).in(Scopes.SINGLETON);
-        tableFunctions.addBinding().toProvider(IcebergTablesFunctionProvider.class).in(Scopes.SINGLETON);
+        newSetBinder(binder, ConnectorTableFunction.class).addBinding().toProvider(TableChangesFunctionProvider.class).in(Scopes.SINGLETON);
         binder.bind(FunctionProvider.class).to(IcebergFunctionProvider.class).in(Scopes.SINGLETON);
         binder.bind(TableChangesFunctionProcessorProviderFactory.class).in(Scopes.SINGLETON);
 

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergSplitManager.java

@@ -21,7 +21,6 @@
 import io.trino.plugin.base.classloader.ClassLoaderSafeConnectorSplitSource;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesFunctionHandle;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesSplitSource;
-import io.trino.plugin.iceberg.functions.tables.IcebergTablesFunction.IcebergTables;
 import io.trino.spi.connector.ConnectorSession;
 import io.trino.spi.connector.ConnectorSplitManager;
 import io.trino.spi.connector.ConnectorSplitSource;
@@ -158,9 +157,6 @@ public ConnectorSplitSource getSplits(
                             .toSnapshot(functionHandle.endSnapshotId()));
             return new ClassLoaderSafeConnectorSplitSource(tableChangesSplitSource, IcebergSplitManager.class.getClassLoader());
         }
-        if (function instanceof IcebergTables icebergTables) {
-            return new ClassLoaderSafeConnectorSplitSource(new FixedSplitSource(icebergTables), IcebergSplitManager.class.getClassLoader());
-        }
 
         throw new IllegalStateException("Unknown table function: " + function);
     }

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/functions/IcebergFunctionProvider.java

@@ -14,20 +14,12 @@
 package io.trino.plugin.iceberg.functions;
 
 import com.google.inject.Inject;
-import io.trino.plugin.base.classloader.ClassLoaderSafeTableFunctionProcessorProvider;
 import io.trino.plugin.base.classloader.ClassLoaderSafeTableFunctionProcessorProviderFactory;
-import io.trino.plugin.base.classloader.ClassLoaderSafeTableFunctionSplitProcessor;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesFunctionHandle;
 import io.trino.plugin.iceberg.functions.tablechanges.TableChangesFunctionProcessorProviderFactory;
-import io.trino.plugin.iceberg.functions.tables.IcebergTablesFunction;
-import io.trino.spi.classloader.ThreadContextClassLoader;
-import io.trino.spi.connector.ConnectorSession;
-import io.trino.spi.connector.ConnectorSplit;
 import io.trino.spi.function.FunctionProvider;
 import io.trino.spi.function.table.ConnectorTableFunctionHandle;
-import io.trino.spi.function.table.TableFunctionProcessorProvider;
 import io.trino.spi.function.table.TableFunctionProcessorProviderFactory;
-import io.trino.spi.function.table.TableFunctionSplitProcessor;
 
 import static java.util.Objects.requireNonNull;
 
@@ -48,28 +40,6 @@ public TableFunctionProcessorProviderFactory getTableFunctionProcessorProviderFa
         if (functionHandle instanceof TableChangesFunctionHandle) {
             return new ClassLoaderSafeTableFunctionProcessorProviderFactory(tableChangesFunctionProcessorProviderFactory, getClass().getClassLoader());
         }
-        if (functionHandle instanceof IcebergTablesFunction.IcebergTables) {
-            ClassLoader classLoader = getClass().getClassLoader();
-            return new TableFunctionProcessorProviderFactory()
-            {
-                @Override
-                public TableFunctionProcessorProvider createTableFunctionProcessorProvider()
-                {
-                    try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(classLoader)) {
-                        return new ClassLoaderSafeTableFunctionProcessorProvider(new TableFunctionProcessorProvider()
-                        {
-                            @Override
-                            public TableFunctionSplitProcessor getSplitProcessor(ConnectorSession session, ConnectorTableFunctionHandle handle, ConnectorSplit split)
-                            {
-                                return new ClassLoaderSafeTableFunctionSplitProcessor(
-                                        new IcebergTablesFunction.IcebergTablesProcessor(((IcebergTablesFunction.IcebergTables) split).tables()),
-                                        getClass().getClassLoader());
-                            }
-                        }, classLoader);
-                    }
-                }
-            };
-        }
 
         throw new UnsupportedOperationException("Unsupported function: " + functionHandle);
     }

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergMinioConnectorSmokeTest.java

@@ -13,14 +13,10 @@
  */
 package io.trino.plugin.iceberg;
 
-import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import io.minio.messages.Event;
 import io.trino.Session;
-import io.trino.metastore.Column;
 import io.trino.metastore.HiveMetastore;
-import io.trino.metastore.HiveType;
-import io.trino.metastore.Table;
 import io.trino.plugin.hive.containers.Hive3MinioDataLake;
 import io.trino.plugin.hive.metastore.thrift.BridgingHiveMetastore;
 import io.trino.testing.QueryRunner;
@@ -32,25 +28,18 @@
 
 import java.util.List;
 import java.util.Map;
-import java.util.Optional;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
 import static com.google.common.collect.ImmutableList.toImmutableList;
 import static com.google.common.collect.ImmutableSet.toImmutableSet;
-import static io.trino.metastore.PrincipalPrivileges.NO_PRIVILEGES;
-import static io.trino.plugin.hive.TableType.EXTERNAL_TABLE;
 import static io.trino.plugin.hive.TestingThriftHiveMetastoreBuilder.testingThriftHiveMetastoreBuilder;
-import static io.trino.plugin.iceberg.IcebergTestUtils.getHiveMetastore;
-import static io.trino.plugin.iceberg.catalog.AbstractIcebergTableOperations.ICEBERG_METASTORE_STORAGE_FORMAT;
 import static io.trino.testing.TestingNames.randomNameSuffix;
 import static io.trino.testing.containers.Minio.MINIO_ACCESS_KEY;
 import static io.trino.testing.containers.Minio.MINIO_REGION;
 import static io.trino.testing.containers.Minio.MINIO_SECRET_KEY;
 import static java.lang.String.format;
 import static java.util.Locale.ENGLISH;
-import static org.apache.iceberg.BaseMetastoreTableOperations.ICEBERG_TABLE_TYPE_VALUE;
-import static org.apache.iceberg.BaseMetastoreTableOperations.TABLE_TYPE_PROP;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.junit.jupiter.api.parallel.ExecutionMode.SAME_THREAD;
 
@@ -245,25 +234,6 @@ public void testPathContainsSpecialCharacter()
         assertUpdate("DROP TABLE " + tableName);
     }
 
-    @Override
-    protected AutoCloseable createAdditionalTables(String schema)
-    {
-        HiveMetastore metastore = getHiveMetastore(getQueryRunner());
-        // simulate iceberg table created by spark with lowercase table type
-        Table lowerCaseTableType = io.trino.metastore.Table.builder()
-                .setDatabaseName(schema)
-                .setTableName("lowercase_type_" + randomNameSuffix())
-                .setOwner(Optional.empty())
-                .setDataColumns(ImmutableList.of(new Column("id", HiveType.HIVE_STRING, Optional.empty(), ImmutableMap.of())))
-                .setTableType(EXTERNAL_TABLE.name())
-                .withStorage(storage -> storage.setStorageFormat(ICEBERG_METASTORE_STORAGE_FORMAT))
-                .setParameter("EXTERNAL", "TRUE")
-                .setParameter(TABLE_TYPE_PROP, ICEBERG_TABLE_TYPE_VALUE.toLowerCase(ENGLISH))
-                .build();
-        metastore.createTable(lowerCaseTableType, NO_PRIVILEGES);
-        return () -> metastore.dropTable(lowerCaseTableType.getDatabaseName(), lowerCaseTableType.getTableName(), true);
-    }
-
     private String onMetastore(@Language("SQL") String sql)
     {
         return hiveMinioDataLake.getHiveHadoop().runOnMetastore(sql);

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseSharedMetastoreTest.java

@@ -152,13 +152,6 @@ public void testShowSchemas()
         assertThat(showCreateIcebergWithRedirectionsSchema).isEqualTo(getExpectedIcebergCreateSchema("iceberg_with_redirections"));
     }
 
-    @Test
-    public void testIcebergTablesFunction()
-    {
-        assertQuery("SELECT * FROM TABLE(iceberg.system.iceberg_tables(SCHEMA_NAME => '%s'))".formatted(tpchSchema), "VALUES ('%s', 'nation')".formatted(tpchSchema));
-        assertQuery("SELECT * FROM TABLE(iceberg_with_redirections.system.iceberg_tables(SCHEMA_NAME => '%s'))".formatted(tpchSchema), "VALUES ('%s', 'nation')".formatted(tpchSchema));
-    }
-
     @Test
     public void testTimeTravelWithRedirection()
             throws InterruptedException

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/rest/TestIcebergUnityRestCatalogConnectorSmokeTest.java

@@ -95,7 +95,7 @@ protected String getMetadataLocation(String tableName)
     @Override
     protected String schemaPath()
     {
-        return format("%s/%s", warehouseLocation, getSession().getSchema().orElseThrow());
+        return format("%s/%s", warehouseLocation, getSession().getSchema());
     }
 
     @Override
@@ -470,7 +470,7 @@ public void testDropTableWithMissingDataFile()
     public void testDropTableWithNonExistentTableLocation()
     {
         assertThatThrownBy(super::testDropTableWithNonExistentTableLocation)
-                .hasStackTraceContaining("Access Denied");
+                .hasMessageContaining("Access Denied");
     }
 
     @Test