Package org.apache.flink.table.workflow
-
Interface Summary Interface Description CreateRefreshWorkflow CreateRefreshWorkflow
provides the related information to create refresh workflow ofCatalogMaterializedTable
.ModifyRefreshWorkflow<T extends RefreshHandler> ModifyRefreshWorkflow
provides the related information to modify refresh workflow ofCatalogMaterializedTable
.RefreshWorkflow RefreshWorkflow
is the basic interface that provide the related information to operate the refresh workflow ofCatalogMaterializedTable
, the operation of refresh workflow include create, modify, drop, etc.WorkflowScheduler<T extends RefreshHandler> This interface is used to interact with specific workflow scheduler services that support creating, modifying, and deleting refreshed workflow of Materialized Table. -
Class Summary Class Description CreatePeriodicRefreshWorkflow CreateRefreshWorkflow
provides the related information to create periodic refresh workflow ofCatalogMaterializedTable
.DeleteRefreshWorkflow<T extends RefreshHandler> DeleteRefreshWorkflow
provides the related information to delete refresh workflow ofCatalogMaterializedTable
.ResumeRefreshWorkflow<T extends RefreshHandler> ModifyRefreshWorkflow
provides the related information to resume refresh workflow ofCatalogMaterializedTable
.SuspendRefreshWorkflow<T extends RefreshHandler> ModifyRefreshWorkflow
provides the related information to suspend refresh workflow ofCatalogMaterializedTable
. -
Exception Summary Exception Description WorkflowException A workflow-related operation exception to materialized table, including create, suspend, resume, drop workflow operation, etc.