org.apache.flink.connector.base.table

Class AsyncDynamicTableSinkFactory

java.lang.Object

org.apache.flink.connector.base.table.AsyncDynamicTableSinkFactory

All Implemented Interfaces:

DynamicTableFactory, DynamicTableSinkFactory, Factory

@PublicEvolving
public abstract class AsyncDynamicTableSinkFactory
extends Object
implements DynamicTableSinkFactory

Abstract Implementation of DynamicTableSinkFactory having AsyncSinkBase fields as optional table options defined in AsyncSinkConnectorOptions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AsyncDynamicTableSinkFactory.AsyncDynamicSinkContext Class providing common table data required by AsyncDynamicTableSinkFactory to create AsyncDynamicTableSink.

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

DynamicTableFactory.Context

Constructor Summary

Constructors

Constructor and Description
AsyncDynamicTableSinkFactory()

Method Summary

Modifier and Type	Method and Description
protected AsyncDynamicTableSinkBuilder<?,?>	addAsyncOptionsToBuilder(Properties configuration, AsyncDynamicTableSinkBuilder<?,?> builder)
Set<ConfigOption<?>>	optionalOptions() Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.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.DynamicTableSinkFactory

createDynamicTableSink

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

forwardOptions

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

factoryIdentifier, requiredOptions

Constructor Detail

AsyncDynamicTableSinkFactory

public AsyncDynamicTableSinkFactory()

Method Detail

optionalOptions

public Set<ConfigOption<?>> optionalOptions()

Description copied from interface: Factory

Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().

See the documentation of Factory for more information.

Specified by:

optionalOptions in interface Factory

addAsyncOptionsToBuilder

protected AsyncDynamicTableSinkBuilder<?,?> addAsyncOptionsToBuilder(Properties configuration,
                                                                     AsyncDynamicTableSinkBuilder<?,?> builder)