Class DelegateExecutorFactory
- java.lang.Object
-
- org.apache.flink.table.planner.loader.DelegateExecutorFactory
-
- All Implemented Interfaces:
org.apache.flink.table.delegation.ExecutorFactory,org.apache.flink.table.delegation.StreamExecutorFactory,org.apache.flink.table.factories.Factory
@Internal public class DelegateExecutorFactory extends Object implements org.apache.flink.table.delegation.StreamExecutorFactory
Delegate ofExecutorFactory.
-
-
Constructor Summary
Constructors Constructor Description DelegateExecutorFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.table.delegation.Executorcreate(org.apache.flink.configuration.Configuration configuration)org.apache.flink.table.delegation.Executorcreate(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecutionEnvironment)StringfactoryIdentifier()Set<org.apache.flink.configuration.ConfigOption<?>>optionalOptions()Set<org.apache.flink.configuration.ConfigOption<?>>requiredOptions()
-
-
-
Method Detail
-
create
public org.apache.flink.table.delegation.Executor create(org.apache.flink.configuration.Configuration configuration)
- Specified by:
createin interfaceorg.apache.flink.table.delegation.ExecutorFactory
-
create
public org.apache.flink.table.delegation.Executor create(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecutionEnvironment)
- Specified by:
createin interfaceorg.apache.flink.table.delegation.StreamExecutorFactory
-
factoryIdentifier
public String factoryIdentifier()
- Specified by:
factoryIdentifierin interfaceorg.apache.flink.table.factories.Factory
-
requiredOptions
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
- Specified by:
requiredOptionsin interfaceorg.apache.flink.table.factories.Factory
-
optionalOptions
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
- Specified by:
optionalOptionsin interfaceorg.apache.flink.table.factories.Factory
-
-