public class FlinkGenericTableFactory extends Object implements org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.DynamicTableSinkFactory
Constructor and Description |
---|
FlinkGenericTableFactory(org.apache.flink.table.factories.Factory paimon,
org.apache.flink.table.factories.Factory flink) |
Modifier and Type | Method and 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) |
String |
factoryIdentifier() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
optionalOptions() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
requiredOptions() |
public FlinkGenericTableFactory(org.apache.flink.table.factories.Factory paimon, org.apache.flink.table.factories.Factory flink)
public String factoryIdentifier()
factoryIdentifier
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
requiredOptions
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
optionalOptions
in interface org.apache.flink.table.factories.Factory
public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
createDynamicTableSink
in interface org.apache.flink.table.factories.DynamicTableSinkFactory
public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
createDynamicTableSource
in interface org.apache.flink.table.factories.DynamicTableSourceFactory
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.