[flink] 02/03: [hotfix][table-common] Enable receiving isBounded in DynamicTableSink

[tw...@apache.org]

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 <tw...@apache.org>
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.
 		 *