This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5adbba8d6abff400539399e1a42cc2f7b71137ff Author: Timo Walther <[email protected]> AuthorDate: Thu Apr 30 10:30:29 2020 +0200 [hotfix][table-common] Enable receiving isBounded in DynamicTableSink --- .../org/apache/flink/table/connector/sink/DynamicTableSink.java | 7 +++++++ 1 file changed, 7 insertions(+) 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 b573916..97595f1 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 @@ -125,6 +125,13 @@ public interface DynamicTableSink { interface Context { /** + * Returns whether a runtime implementation can expect a finite number of rows. + * + * <p>This information might be derived from the session's execution mode and/or kind of query. + */ + boolean isBounded(); + + /** * Creates a converter for mapping between Flink's internal data structures and objects specified * by the given {@link DataType} that can be passed into a runtime implementation. *
