THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
interface StatementSet {
/**
* Asynchronously execute the dml statements as a batch
*/
CompletableFuture<ResultTable> executeAsync();
} |
Add an async execute method to org.apache.flink.table.delegation.Executor
| Code Block | ||||
|---|---|---|---|---|
| ||||
/**
* Executes all the previously applied transformations via {@link #apply(List)} in an async way.
* @return
* @throws Exception
*/
CompletableFuture<JobClient> executeAsync(String jobName) throws Exception; |
SQL CLI integrates with new API
...