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 2020/05/09 02:01:50 UTC
[flink] 01/03: [hotfix][table-common] Make scan and sink
RuntimeProvider interfaces public
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 288a0af2c4dceab803216b2d44c73f6fabf4499f
Author: Jark Wu <ja...@apache.org>
AuthorDate: Sun May 3 16:53:18 2020 +0800
[hotfix][table-common] Make scan and sink RuntimeProvider interfaces public
---
.../org/apache/flink/table/connector/sink/SinkFunctionProvider.java | 2 +-
.../org/apache/flink/table/connector/source/SourceFunctionProvider.java | 2 +-
.../org/apache/flink/table/connector/sink/OutputFormatProvider.java | 2 +-
.../org/apache/flink/table/connector/source/InputFormatProvider.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
index 60efbe8..87a7533 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
@@ -26,7 +26,7 @@ import org.apache.flink.table.data.RowData;
* Provider of a {@link SinkFunction} instance as a runtime implementation for {@link DynamicTableSink}.
*/
@PublicEvolving
-interface SinkFunctionProvider extends DynamicTableSink.SinkRuntimeProvider {
+public interface SinkFunctionProvider extends DynamicTableSink.SinkRuntimeProvider {
/**
* Helper method for creating a static provider.
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/SourceFunctionProvider.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/SourceFunctionProvider.java
index 23a9b05..a428e0e 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/SourceFunctionProvider.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/SourceFunctionProvider.java
@@ -26,7 +26,7 @@ import org.apache.flink.table.data.RowData;
* Provider of a {@link SourceFunction} instance as a runtime implementation for {@link ScanTableSource}.
*/
@PublicEvolving
-interface SourceFunctionProvider extends ScanTableSource.ScanRuntimeProvider {
+public interface SourceFunctionProvider extends ScanTableSource.ScanRuntimeProvider {
/**
* Helper method for creating a static provider.
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java
index 7850685..1feda23 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java
@@ -26,7 +26,7 @@ import org.apache.flink.table.data.RowData;
* Provider of an {@link OutputFormat} instance as a runtime implementation for {@link DynamicTableSink}.
*/
@PublicEvolving
-interface OutputFormatProvider extends DynamicTableSink.SinkRuntimeProvider {
+public interface OutputFormatProvider extends DynamicTableSink.SinkRuntimeProvider {
/**
* Helper method for creating a static provider.
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/InputFormatProvider.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/InputFormatProvider.java
index aa6f76b..51fa1a6 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/InputFormatProvider.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/InputFormatProvider.java
@@ -26,7 +26,7 @@ import org.apache.flink.table.data.RowData;
* Provider of an {@link InputFormat} instance as a runtime implementation for {@link ScanTableSource}.
*/
@PublicEvolving
-interface InputFormatProvider extends ScanTableSource.ScanRuntimeProvider {
+public interface InputFormatProvider extends ScanTableSource.ScanRuntimeProvider {
/**
* Helper method for creating a static provider.