Class 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 of ExecutorFactory.
    • Constructor Detail

      • DelegateExecutorFactory

        public DelegateExecutorFactory()
    • Method Detail

      • create

        public org.apache.flink.table.delegation.Executor create​(org.apache.flink.configuration.Configuration configuration)
        Specified by:
        create in interface org.apache.flink.table.delegation.ExecutorFactory
      • create

        public org.apache.flink.table.delegation.Executor create​(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecutionEnvironment)
        Specified by:
        create in interface org.apache.flink.table.delegation.StreamExecutorFactory
      • factoryIdentifier

        public String factoryIdentifier()
        Specified by:
        factoryIdentifier in interface org.apache.flink.table.factories.Factory
      • requiredOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
        Specified by:
        requiredOptions in interface org.apache.flink.table.factories.Factory
      • optionalOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
        Specified by:
        optionalOptions in interface org.apache.flink.table.factories.Factory