[FLINK-9160] Make subclasses of RuntimeContext internal that should be internal


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/179ae583
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/179ae583
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/179ae583

Branch: refs/heads/release-1.5
Commit: 179ae583e2d01f78d5c214198ffc6ffb75148c7d
Parents: 1f21af6
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Wed Apr 11 19:40:04 2018 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Apr 12 08:08:31 2018 -0700

----------------------------------------------------------------------
 .../api/common/functions/util/AbstractRuntimeUDFContext.java     | 3 ++-
 .../flink/streaming/api/operators/StreamingRuntimeContext.java   | 4 ++--
 2 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/179ae583/flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
----------------------------------------------------------------------
diff --git 
a/flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
 
b/flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
index d0d7e52..6246e80 100644
--- 
a/flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
+++ 
b/flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.api.common.functions.util;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.annotation.PublicEvolving;
 import org.apache.flink.api.common.ExecutionConfig;
 import org.apache.flink.api.common.TaskInfo;
@@ -54,7 +55,7 @@ import static 
org.apache.flink.util.Preconditions.checkNotNull;
 /**
  * A standalone implementation of the {@link RuntimeContext}, created by 
runtime UDF operators.
  */
-@PublicEvolving
+@Internal
 public abstract class AbstractRuntimeUDFContext implements RuntimeContext {
 
        private final TaskInfo taskInfo;

http://git-wip-us.apache.org/repos/asf/flink/blob/179ae583/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
----------------------------------------------------------------------
diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
index cb40214..1f42ccf 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
@@ -18,7 +18,7 @@
 
 package org.apache.flink.streaming.api.operators;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.accumulators.Accumulator;
 import org.apache.flink.api.common.functions.BroadcastVariableInitializer;
 import org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext;
@@ -50,7 +50,7 @@ import java.util.Map;
  * Implementation of the {@link 
org.apache.flink.api.common.functions.RuntimeContext},
  * for streaming operators.
  */
-@PublicEvolving
+@Internal
 public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
 
        /** The operator to which this function belongs. */

Reply via email to