org.apache.flink.table.planner.loader

Class DelegateExecutorFactory

java.lang.Object

org.apache.flink.table.planner.loader.DelegateExecutorFactory

All Implemented Interfaces:

ExecutorFactory, StreamExecutorFactory, Factory

@Internal
public class DelegateExecutorFactory
extends Object
implements StreamExecutorFactory

Delegate of ExecutorFactory.

Field Summary

Fields inherited from interface org.apache.flink.table.delegation.ExecutorFactory

DEFAULT_IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
DelegateExecutorFactory()

Method Summary

Modifier and Type	Method and Description
Executor	create(Configuration configuration) Creates a corresponding Executor.
Executor	create(StreamExecutionEnvironment streamExecutionEnvironment) Creates a corresponding Executor.
String	factoryIdentifier() Returns a unique identifier among same factory interfaces.
Set<ConfigOption<?>>	optionalOptions() Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
Set<ConfigOption<?>>	requiredOptions() Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().

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.Factory

factoryIdentifier, optionalOptions, requiredOptions

Constructor Detail

DelegateExecutorFactory

public DelegateExecutorFactory()

Method Detail

create

public Executor create(Configuration configuration)

Description copied from interface: ExecutorFactory

Creates a corresponding Executor.

Specified by:

create in interface ExecutorFactory

create

public Executor create(StreamExecutionEnvironment streamExecutionEnvironment)

Description copied from interface: StreamExecutorFactory

Creates a corresponding Executor.

This method will be used when instantiating a TableEnvironment from one of the bridging modules which enables conversion from/to DataStream API.

Specified by:

create in interface StreamExecutorFactory

factoryIdentifier

public String factoryIdentifier()

Description copied from interface: Factory

Returns a unique identifier among same factory interfaces.

For consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended using "-" (e.g. elasticsearch-7).

Specified by:

factoryIdentifier in interface Factory

requiredOptions

public Set<ConfigOption<?>> requiredOptions()

Description copied from interface: Factory

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

See the documentation of Factory for more information.

Specified by:

requiredOptions in interface Factory

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