@Test public void testLoadTableFromCatalog() throws IOException { conf.set("warehouse.location", temp.newFolder("hadoop", "warehouse").toString()); conf.setClass(InputFormatConfig.CATALOG_LOADER_CLASS, CustomHadoopCatalogLoader.class, CatalogLoader.class); AssertHelpers.assertThrows( "Should complain about table identifier not set", IllegalArgumentException.class, "identifier not set", () -> Catalogs.loadTable(conf)); HadoopCatalog catalog = new CustomHadoopCatalog(conf); Table hadoopCatalogTable = catalog.createTable(TableIdentifier.of("table"), SCHEMA); conf.set(InputFormatConfig.TABLE_IDENTIFIER, "table"); Assert.assertEquals(hadoopCatalogTable.location(), Catalogs.loadTable(conf).location()); }
public static Table loadTable(Configuration conf) { return loadTable(conf, conf.get(InputFormatConfig.TABLE_IDENTIFIER), conf.get(InputFormatConfig.TABLE_LOCATION)); }
Catalogs { public static Table loadTable(Configuration conf) { return loadTable(conf, conf.get(InputFormatConfig.TABLE_IDENTIFIER), conf.get(InputFormatConfig.TABLE_LOCATION)); } }
Catalogs { public static Table loadTable(Configuration conf) { return loadTable(conf, conf.get(InputFormatConfig.TABLE_IDENTIFIER), conf.get(InputFormatConfig.TABLE_LOCATION)); } private  Catalogs(); }
Catalogs { public static Table loadTable(Configuration conf) { return loadTable(conf, conf.get(InputFormatConfig.TABLE_IDENTIFIER), conf.get(InputFormatConfig.TABLE_LOCATION)); } private  Catalogs(); static Table loadTable(Configuration conf); static Table loadTable(Configuration conf, Properties props); }
Catalogs { public static Table loadTable(Configuration conf) { return loadTable(conf, conf.get(InputFormatConfig.TABLE_IDENTIFIER), conf.get(InputFormatConfig.TABLE_LOCATION)); } private  Catalogs(); static Table loadTable(Configuration conf); static Table loadTable(Configuration conf, Properties props);  }