Class EmbeddedWorkflowSchedulerFactory

  • All Implemented Interfaces:
    org.apache.flink.table.factories.Factory, org.apache.flink.table.factories.WorkflowSchedulerFactory

    @PublicEvolving
    public class EmbeddedWorkflowSchedulerFactory
    extends Object
    implements org.apache.flink.table.factories.WorkflowSchedulerFactory
    The WorkflowSchedulerFactory to create the EmbeddedWorkflowScheduler.
    • Constructor Detail

      • EmbeddedWorkflowSchedulerFactory

        public EmbeddedWorkflowSchedulerFactory()
    • Method Detail

      • 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
      • createWorkflowScheduler

        public org.apache.flink.table.workflow.WorkflowScheduler<?> createWorkflowScheduler​(org.apache.flink.table.factories.WorkflowSchedulerFactory.Context context)
        Specified by:
        createWorkflowScheduler in interface org.apache.flink.table.factories.WorkflowSchedulerFactory