You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/02/25 10:31:53 UTC
[flink] branch master updated (63dc7f7 -> 7fd4767)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 63dc7f7 fixup! [FLINK-21453][checkpointing][refactor] Replace advanceToEndOfTime with new CheckpointType.SAVEPOINT_TERMINATE
add 7fd4767 [FLINK-18550][sql-client] Use TableResult#collect to get SELECT result for sql client
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/dev/table/sqlClient.md | 11 +-
docs/content/docs/dev/table/sqlClient.md | 11 +-
.../flink-sql-client/conf/sql-client-defaults.yaml | 14 --
flink-table/flink-sql-client/pom.xml | 8 +
.../table/client/cli/CliChangelogResultView.java | 20 +-
.../apache/flink/table/client/cli/CliClient.java | 6 +-
.../apache/flink/table/client/cli/CliStrings.java | 1 -
.../table/client/cli/CliTableauResultView.java | 126 ++++--------
.../client/config/entries/DeploymentEntry.java | 28 +--
.../client/config/entries/ExecutionEntry.java | 4 +-
.../flink/table/client/gateway/Executor.java | 3 +-
.../table/client/gateway/ResultDescriptor.java | 10 +-
.../gateway/local/CollectBatchTableSink.java | 79 --------
.../gateway/local/CollectStreamTableSink.java | 89 ---------
.../table/client/gateway/local/LocalExecutor.java | 150 +++------------
.../table/client/gateway/local/ResultStore.java | 100 ++--------
.../client/gateway/local/result/BasicResult.java | 53 -----
...reamResult.java => ChangelogCollectResult.java} | 39 ++--
.../gateway/local/result/ChangelogResult.java | 11 +-
.../gateway/local/result/CollectResultBase.java | 88 +++++++++
.../gateway/local/result/CollectStreamResult.java | 163 ----------------
.../client/gateway/local/result/DynamicResult.java | 17 +-
.../result/MaterializedCollectBatchResult.java | 144 +++-----------
...ult.java => MaterializedCollectResultBase.java} | 154 ++-------------
.../result/MaterializedCollectStreamResult.java | 171 ++--------------
.../gateway/local/result/MaterializedResult.java | 8 +-
.../table/client/gateway/local/result/Result.java | 33 ----
.../flink/table/client/cli/CliClientTest.java | 5 +-
.../flink/table/client/cli/CliResultViewTest.java | 10 +-
.../table/client/cli/CliTableauResultViewTest.java | 214 ++++++++++++---------
.../flink/table/client/cli/TestingExecutor.java | 13 +-
.../table/client/cli/TestingExecutorBuilder.java | 9 +-
.../client/gateway/local/LocalExecutorITCase.java | 83 ++++----
.../local/result/ChangelogCollectResultTest.java | 74 +++++++
.../result/MaterializedCollectBatchResultTest.java | 148 ++++++++++++++
.../MaterializedCollectStreamResultTest.java | 134 +++++--------
.../test/resources/test-sql-client-catalogs.yaml | 3 -
.../test/resources/test-sql-client-defaults.yaml | 3 -
.../test/resources/test-sql-client-factory.yaml | 3 -
.../test/resources/test-sql-client-modules.yaml | 3 -
.../org/apache/flink/table/utils/PrintUtils.java | 25 ++-
.../utils/TestCollectionTableFactory.scala | 4 +-
42 files changed, 753 insertions(+), 1519 deletions(-)
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/CollectBatchTableSink.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/CollectStreamTableSink.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/BasicResult.java
rename flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/{ChangelogCollectStreamResult.java => ChangelogCollectResult.java} (68%)
create mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/CollectResultBase.java
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/CollectStreamResult.java
copy flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/{MaterializedCollectStreamResult.java => MaterializedCollectResultBase.java} (50%)
delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/Result.java
create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/result/ChangelogCollectResultTest.java
create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/result/MaterializedCollectBatchResultTest.java