org.apache.flink.table.gateway.workflow

Class EmbeddedWorkflowScheduler

java.lang.Object

org.apache.flink.table.gateway.workflow.EmbeddedWorkflowScheduler

All Implemented Interfaces:

org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

@PublicEvolving
public class EmbeddedWorkflowScheduler
extends Object
implements org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

A workflow scheduler plugin implementation for EmbeddedQuartzScheduler. It is used to create, modify refresh workflow for materialized table.

Constructor Summary

Constructors

Constructor and Description
EmbeddedWorkflowScheduler(org.apache.flink.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	close()
EmbeddedRefreshHandler	createRefreshWorkflow(org.apache.flink.table.workflow.CreateRefreshWorkflow createRefreshWorkflow)
void	deleteRefreshWorkflow(org.apache.flink.table.workflow.DeleteRefreshWorkflow<EmbeddedRefreshHandler> deleteRefreshWorkflow)
EmbeddedRefreshHandlerSerializer	getRefreshHandlerSerializer()
void	modifyRefreshWorkflow(org.apache.flink.table.workflow.ModifyRefreshWorkflow<EmbeddedRefreshHandler> modifyRefreshWorkflow)
void	open()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmbeddedWorkflowScheduler

public EmbeddedWorkflowScheduler(org.apache.flink.configuration.Configuration configuration)

Method Detail

open

public void open()
          throws org.apache.flink.table.workflow.WorkflowException

Specified by:

open in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

Throws:

org.apache.flink.table.workflow.WorkflowException

close

public void close()
           throws org.apache.flink.table.workflow.WorkflowException

Specified by:

close in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

Throws:

org.apache.flink.table.workflow.WorkflowException

getRefreshHandlerSerializer

public EmbeddedRefreshHandlerSerializer getRefreshHandlerSerializer()

Specified by:

getRefreshHandlerSerializer in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

createRefreshWorkflow

public EmbeddedRefreshHandler createRefreshWorkflow(org.apache.flink.table.workflow.CreateRefreshWorkflow createRefreshWorkflow)
                                             throws org.apache.flink.table.workflow.WorkflowException

Specified by:

createRefreshWorkflow in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

Throws:

org.apache.flink.table.workflow.WorkflowException

modifyRefreshWorkflow

public void modifyRefreshWorkflow(org.apache.flink.table.workflow.ModifyRefreshWorkflow<EmbeddedRefreshHandler> modifyRefreshWorkflow)
                           throws org.apache.flink.table.workflow.WorkflowException

Specified by:

modifyRefreshWorkflow in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

Throws:

org.apache.flink.table.workflow.WorkflowException

deleteRefreshWorkflow

public void deleteRefreshWorkflow(org.apache.flink.table.workflow.DeleteRefreshWorkflow<EmbeddedRefreshHandler> deleteRefreshWorkflow)
                           throws org.apache.flink.table.workflow.WorkflowException

Specified by:

deleteRefreshWorkflow in interface org.apache.flink.table.workflow.WorkflowScheduler<EmbeddedRefreshHandler>

Throws:

org.apache.flink.table.workflow.WorkflowException