Package org.apache.flink.table.workflow
Class CreatePeriodicRefreshWorkflow
- java.lang.Object
-
- org.apache.flink.table.workflow.CreatePeriodicRefreshWorkflow
-
- All Implemented Interfaces:
CreateRefreshWorkflow
,RefreshWorkflow
@PublicEvolving public class CreatePeriodicRefreshWorkflow extends Object implements CreateRefreshWorkflow
CreateRefreshWorkflow
provides the related information to create periodic refresh workflow ofCatalogMaterializedTable
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getCronExpression()
String
getDescriptionStatement()
Map<String,String>
getExecutionConfig()
Map<String,String>
getInitConfig()
ObjectIdentifier
getMaterializedTableIdentifier()
String
getRestEndpointUrl()
-
-
-
Method Detail
-
getMaterializedTableIdentifier
public ObjectIdentifier getMaterializedTableIdentifier()
-
getDescriptionStatement
public String getDescriptionStatement()
-
getCronExpression
public String getCronExpression()
-
getRestEndpointUrl
public String getRestEndpointUrl()
-
-