You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2019/07/08 08:30:28 UTC
[flink] branch master updated: [hotfix] Revert annotation to
Internal on DataStreamQueryOperation
This is an automated email from the ASF dual-hosted git repository.
kurt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new de6706a [hotfix] Revert annotation to Internal on DataStreamQueryOperation
de6706a is described below
commit de6706ae2bd0019011516aa9851bc3284350853d
Author: Kurt Young <yk...@gmail.com>
AuthorDate: Mon Jul 8 16:30:02 2019 +0800
[hotfix] Revert annotation to Internal on DataStreamQueryOperation
---
.../org/apache/flink/table/operations/DataStreamQueryOperation.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/operations/DataStreamQueryOperation.java b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/operations/DataStreamQueryOperation.java
index cbcab20..7b1d7d2 100644
--- a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/operations/DataStreamQueryOperation.java
+++ b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/operations/DataStreamQueryOperation.java
@@ -18,7 +18,7 @@
package org.apache.flink.table.operations;
-import org.apache.flink.annotation.VisibleForTesting;
+import org.apache.flink.annotation.Internal;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.plan.stats.FlinkStatistic;
@@ -36,7 +36,7 @@ import java.util.Map;
* The {@link DataStreamQueryOperation#getFieldIndices()} describes the mapping between fields of the
* {@link TableSchema} to the {@link org.apache.flink.api.common.typeutils.CompositeType}.
*/
-@VisibleForTesting
+@Internal
public class DataStreamQueryOperation<E> implements QueryOperation {
// DataStreamQueryOperation represent a registered DataStream from `registerDataStream` method