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.
    • Field Summary

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

        DEFAULT_IDENTIFIER
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.table.delegation.Executor create​(org.apache.flink.configuration.Configuration configuration)  
      org.apache.flink.table.delegation.Executor create​(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecutionEnvironment)  
      String factoryIdentifier()  
      Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()  
      Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()  
      • Methods inherited from interface org.apache.flink.table.factories.Factory

        factoryIdentifier, optionalOptions, requiredOptions
    • 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