This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git

commit abb5dfa86bfcc053b3e46a3f40cf2e3e81c36a84
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);
 
        /**

Reply via email to