Timo Theusner created FLINK-41400:
-------------------------------------

             Summary: Refresh a materialized table from the Table API
                 Key: FLINK-41400
                 URL: https://issues.apache.org/jira/browse/FLINK-41400
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / API
            Reporter: Timo Theusner


Add {{MaterializedTable#refresh()}} and {{{}refresh(partitionSpec){}}}, which 
run a one-off batch job on the refresh target and return its 
{{{}RefreshJob{}}}. This also works for {{FULL}} tables from a plain 
{{{}TableEnvironment{}}}.

Proposed Changes
 * Add {{MaterializedTable#refresh()}} and {{{}refresh(Map<String, 
String>){}}}, executing {{AlterMaterializedTableRefreshOperation}}
 * Return a {{RefreshJob}} whose cluster info is resolved at submission



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to