org.apache.iceberg.flink

Class FlinkTableFactory

java.lang.Object

org.apache.iceberg.flink.FlinkDynamicTableFactory

All Implemented Interfaces:

org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSinkFactory<org.apache.flink.table.data.RowData>, org.apache.flink.table.factories.TableSourceFactory<org.apache.flink.table.data.RowData>

public class FlinkTableFactory
extends java.lang.Object
implements org.apache.flink.table.factories.TableSinkFactory<org.apache.flink.table.data.RowData>, org.apache.flink.table.factories.TableSourceFactory<org.apache.flink.table.data.RowData>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

org.apache.flink.table.factories.TableSinkFactory.Context

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSourceFactory

org.apache.flink.table.factories.TableSourceFactory.Context

Constructor Summary

Constructors

Constructor and Description
FlinkTableFactory(FlinkCatalog catalog)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>	createTableSink(org.apache.flink.table.factories.TableSinkFactory.Context context)
org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>	createTableSource(org.apache.flink.table.factories.TableSourceFactory.Context context)
java.util.Map<java.lang.String,java.lang.String>	requiredContext()
java.util.List<java.lang.String>	supportedProperties()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

createTableSink, createTableSink

Methods inherited from interface org.apache.flink.table.factories.TableSourceFactory

createTableSource, createTableSource

Constructor Detail

FlinkTableFactory

public FlinkTableFactory(FlinkCatalog catalog)

Method Detail

createTableSource

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData> createTableSource(org.apache.flink.table.factories.TableSourceFactory.Context context)

Specified by:

createTableSource in interface org.apache.flink.table.factories.TableSourceFactory<org.apache.flink.table.data.RowData>

createTableSink

public org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData> createTableSink(org.apache.flink.table.factories.TableSinkFactory.Context context)

Specified by:

createTableSink in interface org.apache.flink.table.factories.TableSinkFactory<org.apache.flink.table.data.RowData>

requiredContext

public java.util.Map<java.lang.String,java.lang.String> requiredContext()

Specified by:

requiredContext in interface org.apache.flink.table.factories.TableFactory

supportedProperties

public java.util.List<java.lang.String> supportedProperties()

Specified by:

supportedProperties in interface org.apache.flink.table.factories.TableFactory