org.apache.iceberg.flink

Class TableLoader.CatalogTableLoader

java.lang.Object

org.apache.iceberg.flink.TableLoader.CatalogTableLoader

All Implemented Interfaces:

java.io.Closeable, java.io.Serializable, java.lang.AutoCloseable, TableLoader

Enclosing interface:

TableLoader

public static class TableLoader.CatalogTableLoader
extends java.lang.Object
implements TableLoader

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.iceberg.flink.TableLoader

TableLoader.CatalogTableLoader, TableLoader.HadoopTableLoader

Method Summary

Modifier and Type	Method and Description
void	close()
Table	loadTable()
void	open()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.iceberg.flink.TableLoader

fromCatalog, fromHadoopTable, fromHadoopTable

Method Detail

open

public void open()

Specified by:

open in interface TableLoader

loadTable

public Table loadTable()

Specified by:

loadTable in interface TableLoader

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object