This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6cecf624552 [hotfix][docs][table] Fix broken links in determinism.md
(#21643)
add 128b0c4442a [FLINK-30675][sql-client] Decompose query result print
from Executor
No new revisions were added by this update.
Summary of changes:
.../table/client/cli/CliChangelogResultView.java | 55 ++---
.../apache/flink/table/client/cli/CliClient.java | 36 +--
.../flink/table/client/cli/CliInputView.java | 13 +-
.../flink/table/client/cli/CliResultView.java | 19 +-
.../apache/flink/table/client/cli/CliRowView.java | 13 +-
.../flink/table/client/cli/CliTableResultView.java | 73 +++---
.../table/client/cli/CliTableauResultView.java | 32 +--
.../org/apache/flink/table/client/cli/CliView.java | 68 +++--
.../flink/table/client/cli/TerminalUtils.java | 6 +
.../flink/table/client/gateway/Executor.java | 22 --
.../table/client/gateway/ResultDescriptor.java | 59 +++--
.../table/client/gateway/local/LocalExecutor.java | 94 +------
.../table/client/gateway/local/ResultStore.java | 95 -------
.../local/result/ChangelogCollectResult.java | 5 -
.../gateway/local/result/CollectResultBase.java | 17 +-
.../client/gateway/local/result/DynamicResult.java | 8 +-
.../result/MaterializedCollectResultBase.java | 5 -
.../flink/table/client/cli/CliClientTest.java | 25 --
.../flink/table/client/cli/CliResultViewTest.java | 242 +++++-------------
.../table/client/cli/CliTableauResultViewTest.java | 273 +++++++++------------
.../flink/table/client/cli/TestingExecutor.java | 176 -------------
.../table/client/cli/TestingExecutorBuilder.java | 55 -----
.../client/gateway/local/LocalExecutorITCase.java | 28 +--
23 files changed, 395 insertions(+), 1024 deletions(-)
delete mode 100644
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ResultStore.java
delete mode 100644
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/TestingExecutor.java
delete mode 100644
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/TestingExecutorBuilder.java
