Repository: flink Updated Branches: refs/heads/master 76dcbd458 -> 393bceb58
[FLINK-4049] Mark (open/close)IF() @PublicEvolving Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/393bceb5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/393bceb5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/393bceb5 Branch: refs/heads/master Commit: 393bceb5852ae42adf5a1760cb3c1846eb431041 Parents: 76dcbd4 Author: zentol <[email protected]> Authored: Fri Jun 10 13:33:27 2016 +0200 Committer: zentol <[email protected]> Committed: Fri Jun 10 14:18:18 2016 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/flink/api/common/io/RichInputFormat.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/393bceb5/flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java index 188be50..6ab5cc1 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/io/RichInputFormat.java @@ -19,6 +19,7 @@ c * Licensed to the Apache Software Foundation (ASF) under one package org.apache.flink.api.common.io; import org.apache.flink.annotation.Public; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.api.common.functions.RuntimeContext; import org.apache.flink.core.io.InputSplit; @@ -56,6 +57,7 @@ public abstract class RichInputFormat<OT, T extends InputSplit> implements Input * * @see InputFormat */ + @PublicEvolving public void openInputFormat() { //do nothing here, just for subclasses } @@ -66,6 +68,7 @@ public abstract class RichInputFormat<OT, T extends InputSplit> implements Input * * @see InputFormat */ + @PublicEvolving public void closeInputFormat() { //do nothing here, just for subclasses }
