You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2018/04/12 15:50:02 UTC
[3/5] flink git commit: [FLINK-9160] Make subclasses of
RuntimeContext internal that should be internal
[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/d5d6842f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d5d6842f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d5d6842f
Branch: refs/heads/master
Commit: d5d6842f62d5a476541d68e75ed630f30a29d91e
Parents: 612e2d8
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Apr 11 19:40:04 2018 -0700
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Thu Apr 12 08:04:30 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/d5d6842f/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/d5d6842f/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. */