Package org.apache.iceberg.flink
Interface TableLoader
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
,java.io.Serializable
- All Known Implementing Classes:
TableLoader.CatalogTableLoader
,TableLoader.HadoopTableLoader
public interface TableLoader extends java.io.Closeable, java.io.Serializable
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
TableLoader.CatalogTableLoader
static class
TableLoader.HadoopTableLoader
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static TableLoader
fromCatalog(CatalogLoader catalogLoader, TableIdentifier identifier)
static TableLoader
fromHadoopTable(java.lang.String location)
static TableLoader
fromHadoopTable(java.lang.String location, org.apache.hadoop.conf.Configuration hadoopConf)
Table
loadTable()
void
open()
-
-
-
Method Detail
-
open
void open()
-
loadTable
Table loadTable()
-
fromCatalog
static TableLoader fromCatalog(CatalogLoader catalogLoader, TableIdentifier identifier)
-
fromHadoopTable
static TableLoader fromHadoopTable(java.lang.String location)
-
fromHadoopTable
static TableLoader fromHadoopTable(java.lang.String location, org.apache.hadoop.conf.Configuration hadoopConf)
-
-