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)