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, java.lang.Cloneable, 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
TableLoader	clone() Clone a TableLoader
void	close()
boolean	isOpen()
Table	loadTable()
void	open()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

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 java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

clone

public TableLoader clone()

Description copied from interface: TableLoader

Clone a TableLoader

Specified by:

clone in interface TableLoader

Overrides:

clone in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object