Package org.apache.iceberg.flink

Class TableLoader.CatalogTableLoader

java.lang.Object

org.apache.iceberg.flink.TableLoader.CatalogTableLoader

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Cloneable, TableLoader

Enclosing interface:

TableLoader

public static class TableLoader.CatalogTableLoader
extends 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	Description
TableLoader	clone()	Clone a TableLoader
void	close()
boolean	isOpen()
Table	loadTable()
void	open()
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

open

public void open()

Specified by:

open in interface TableLoader

isOpen

public boolean isOpen()

Specified by:

isOpen in interface TableLoader

loadTable

public Table loadTable()

Specified by:

loadTable in interface TableLoader

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

clone

public TableLoader clone()

Description copied from interface: TableLoader

Clone a TableLoader

Specified by:

clone in interface TableLoader

Overrides:

clone in class Object

toString

public String toString()

Overrides:

toString in class Object