...
Current state: "Under Discussion"
Discussion thread: TBD (<- link to https://mail-archiveslists.apache.org/thread/qkvh9p5w9b12s7ykh3l7lv7m9dbgnf1gmod_mbox/flink-dev/)
JIRA: TBD
Released: <Flink Version>
...
To support the new statements, we need to introduce new SQL operators for SQL parser and new SQL operations for the planner.
SQL operator | SQL operation |
SqlShowQueries | ShowQueriesOperation |
SqlStopQuery | StopQueryOperation |
SqlCancelQuery | CancelQueryOperation |
SqlTriggerSavepoint | TriggerSavepointOperation |
SqlDisposeSavepoint | DisposeSavepointOperation |
Executor
Executor would need to convert the query lifecycle operations into ClusterClient commands.
SQL operation | Cluster Client Command |
ShowQueriesOperation | ClusterClient#listJobs |
StopQueryOperation | ClusterClient#stoplWithSavepoint |
CancelQueryOperation | ClusterClient#cancel |
TriggerSavepointOperation | ClusterClient#triggerSavepoint |
DisposeSavepointOperation | ClusterClient#disposeSavepoint |
Implementation Plan
The implementation plan would be simple:
...