Package org.apache.flink.table.workflow
Class SuspendRefreshWorkflow<T extends RefreshHandler>
- java.lang.Object
-
- org.apache.flink.table.workflow.SuspendRefreshWorkflow<T>
-
- All Implemented Interfaces:
ModifyRefreshWorkflow<T>
,RefreshWorkflow
@PublicEvolving public class SuspendRefreshWorkflow<T extends RefreshHandler> extends Object implements ModifyRefreshWorkflow<T>
ModifyRefreshWorkflow
provides the related information to suspend refresh workflow ofCatalogMaterializedTable
.
-
-
Constructor Summary
Constructors Constructor Description SuspendRefreshWorkflow(T refreshHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
getRefreshHandler()
ReturnRefreshHandler
from correspondingWorkflowScheduler
which provides meta info to points to the refresh workflow in scheduler service.
-
-
-
Constructor Detail
-
SuspendRefreshWorkflow
public SuspendRefreshWorkflow(T refreshHandler)
-
-
Method Detail
-
getRefreshHandler
public T getRefreshHandler()
Description copied from interface:ModifyRefreshWorkflow
ReturnRefreshHandler
from correspondingWorkflowScheduler
which provides meta info to points to the refresh workflow in scheduler service.- Specified by:
getRefreshHandler
in interfaceModifyRefreshWorkflow<T extends RefreshHandler>
-
-