FlinkDynamicTableFactory

java.lang.Object
- org.apache.iceberg.flink.FlinkDynamicTableFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory
```
public class FlinkDynamicTableFactory
extends java.lang.Object
implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory
```

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory
  org.apache.flink.table.factories.DynamicTableFactory.Context

Constructor Summary

Constructors
Constructor Description

FlinkDynamicTableFactory()

FlinkDynamicTableFactory(FlinkCatalog catalog)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.table.connector.sink.DynamicTableSink`	`createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)`
`org.apache.flink.table.connector.source.DynamicTableSource`	`createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)`
`java.lang.String`	`factoryIdentifier()`
`java.util.Set<org.apache.flink.configuration.ConfigOption<?>>`	`optionalOptions()`
`java.util.Set<org.apache.flink.configuration.ConfigOption<?>>`	`requiredOptions()`

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.DynamicTableFactory
forwardOptions

Constructor Detail

FlinkDynamicTableFactory
```
public FlinkDynamicTableFactory()
```

FlinkDynamicTableFactory

public FlinkDynamicTableFactory(FlinkCatalog catalog)

Method Detail
- createDynamicTableSource
```
public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
```
  Specified by:
  
  createDynamicTableSource in interface org.apache.flink.table.factories.DynamicTableSourceFactory
- createDynamicTableSink
```
public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
```
  Specified by:
  
  createDynamicTableSink in interface org.apache.flink.table.factories.DynamicTableSinkFactory
- requiredOptions
```
public java.util.Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
```
  Specified by:
  
  requiredOptions in interface org.apache.flink.table.factories.Factory
- optionalOptions
```
public java.util.Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
```
  Specified by:
  
  optionalOptions in interface org.apache.flink.table.factories.Factory
- factoryIdentifier
```
public java.lang.String factoryIdentifier()
```
  Specified by:
  
  factoryIdentifier in interface org.apache.flink.table.factories.Factory