Package org.apache.flink.table.workflow
Class DeleteRefreshWorkflow<T extends RefreshHandler>
- java.lang.Object
-
- org.apache.flink.table.workflow.DeleteRefreshWorkflow<T>
-
- Type Parameters:
T
- The type ofRefreshHandler
used by specificWorkflowScheduler
to locate the refresh workflow in scheduler service.
- All Implemented Interfaces:
RefreshWorkflow
@PublicEvolving public class DeleteRefreshWorkflow<T extends RefreshHandler> extends Object implements RefreshWorkflow
DeleteRefreshWorkflow
provides the related information to delete refresh workflow ofCatalogMaterializedTable
.
-
-
Constructor Summary
Constructors Constructor Description DeleteRefreshWorkflow(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
-
DeleteRefreshWorkflow
public DeleteRefreshWorkflow(T refreshHandler)
-
-
Method Detail
-
getRefreshHandler
public T getRefreshHandler()
ReturnRefreshHandler
from correspondingWorkflowScheduler
which provides meta info to points to the refresh workflow in scheduler service.
-
-