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 8d37909e3bc33bca2a5dbb4eda10951a52fd231f Author: Dawid Wysakowicz <dwysakow...@apache.org> AuthorDate: Wed Jul 24 09:12:44 2019 +0200 [FLINK-13350][table-api-java] Annotate useCatalog & useDatabase with experimental annotation --- .../src/main/java/org/apache/flink/annotation/Experimental.java | 2 +- .../src/main/java/org/apache/flink/table/api/TableEnvironment.java | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/flink-annotations/src/main/java/org/apache/flink/annotation/Experimental.java b/flink-annotations/src/main/java/org/apache/flink/annotation/Experimental.java index 7ddcb1a..d777452 100644 --- a/flink-annotations/src/main/java/org/apache/flink/annotation/Experimental.java +++ b/flink-annotations/src/main/java/org/apache/flink/annotation/Experimental.java @@ -34,7 +34,7 @@ import java.lang.annotation.Target; * */ @Documented -@Target(ElementType.TYPE) +@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR }) @Public public @interface Experimental { } diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java index c396c53..d7e9d7e 100644 --- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java +++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java @@ -18,6 +18,7 @@ package org.apache.flink.table.api; +import org.apache.flink.annotation.Experimental; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.api.common.JobExecutionResult; import org.apache.flink.api.common.typeinfo.TypeInformation; @@ -478,6 +479,7 @@ public interface TableEnvironment { * @param catalogName The name of the catalog to set as the current default catalog. * @see TableEnvironment#useDatabase(String) */ + @Experimental void useCatalog(String catalogName); /** @@ -544,6 +546,7 @@ public interface TableEnvironment { * @param databaseName The name of the database to set as the current database. * @see TableEnvironment#useCatalog(String) */ + @Experimental void useDatabase(String databaseName); /**