This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7655fcd9fbc1126d251a33c8fb69e86b628ddea9 Author: Timo Walther <[email protected]> AuthorDate: Mon Jun 22 17:20:39 2020 +0200 [hotfix][table-common] Fix typos in docs of new source/sink interfaces --- .../java/org/apache/flink/table/connector/sink/DynamicTableSink.java | 2 +- .../org/apache/flink/table/connector/source/LookupTableSource.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java index 6e33371..3a1c857 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java @@ -41,7 +41,7 @@ import java.io.Serializable; * <p>Dynamic tables are the core concept of Flink's Table & SQL API for processing both bounded and * unbounded data in a unified fashion. By definition, a dynamic table can change over time. * - * <p>When writing a dynamic table, the content can either be considered as a changelog (finite or + * <p>When writing a dynamic table, the content can always be considered as a changelog (finite or * infinite) for which all changes are written out continuously until the changelog is exhausted. The * given {@link ChangelogMode} indicates the set of changes that the sink accepts during runtime. * diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java index 363873e..e0b17d5 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java @@ -27,8 +27,8 @@ import java.io.Serializable; * A {@link DynamicTableSource} that looks up rows of an external storage system by one or more keys * during runtime. * - * <p>Compared to {@link ScanTableSource}, the source must not read the entire table and can lazily fetch - * individual values from a (possibly continuously changing) external table when necessary. + * <p>Compared to {@link ScanTableSource}, the source does not have to read the entire table and can + * lazily fetch individual values from a (possibly continuously changing) external table when necessary. * * <p>Note: Compared to {@link ScanTableSource}, a {@link LookupTableSource} does only support emitting * insert-only changes currently (see also {@link RowKind}). Further abilities are not supported.
