[hotfix] [core] Add missing @PublicEvolving annotations to classes in flink-core.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0aa9918c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0aa9918c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0aa9918c Branch: refs/heads/master Commit: 0aa9918cc5b56682087c2c19eb31d9b321c97875 Parents: 391efd3 Author: Fabian Hueske <[email protected]> Authored: Wed Feb 15 15:25:01 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Mon Feb 20 01:01:23 2017 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/api/common/Archiveable.java | 3 +++ .../java/org/apache/flink/configuration/SecurityOptions.java | 3 +++ .../java/org/apache/flink/core/io/VersionMismatchException.java | 5 ++++- .../src/main/java/org/apache/flink/core/io/Versioned.java | 3 +++ .../org/apache/flink/core/io/VersionedIOReadableWritable.java | 4 +++- .../apache/flink/migration/util/MigrationInstantiationUtil.java | 4 +++- .../java/org/apache/flink/migration/util/SerializedValue.java | 2 ++ 7 files changed, 21 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java b/flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java index 09a3a0c..69e050d 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java @@ -17,8 +17,11 @@ */ package org.apache.flink.api.common; +import org.apache.flink.annotation.PublicEvolving; + import java.io.Serializable; +@PublicEvolving public interface Archiveable<T extends Serializable> { T archive(); } http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java index 67d101d..95cf0c7 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java @@ -18,11 +18,14 @@ package org.apache.flink.configuration; +import org.apache.flink.annotation.PublicEvolving; + import static org.apache.flink.configuration.ConfigOptions.key; /** * The set of configuration options relating to security. */ +@PublicEvolving public class SecurityOptions { // ------------------------------------------------------------------------ http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/core/io/VersionMismatchException.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/io/VersionMismatchException.java b/flink-core/src/main/java/org/apache/flink/core/io/VersionMismatchException.java index 3ff88e9..92fd4f4 100644 --- a/flink-core/src/main/java/org/apache/flink/core/io/VersionMismatchException.java +++ b/flink-core/src/main/java/org/apache/flink/core/io/VersionMismatchException.java @@ -18,11 +18,14 @@ package org.apache.flink.core.io; +import org.apache.flink.annotation.PublicEvolving; + import java.io.IOException; /** * This exception signals that incompatible versions have been found during serialization. */ +@PublicEvolving public class VersionMismatchException extends IOException { private static final long serialVersionUID = 7024258967585372438L; @@ -41,4 +44,4 @@ public class VersionMismatchException extends IOException { public VersionMismatchException(Throwable cause) { super(cause); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/core/io/Versioned.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/io/Versioned.java b/flink-core/src/main/java/org/apache/flink/core/io/Versioned.java index b36d5e8..786bf73 100644 --- a/flink-core/src/main/java/org/apache/flink/core/io/Versioned.java +++ b/flink-core/src/main/java/org/apache/flink/core/io/Versioned.java @@ -18,10 +18,13 @@ package org.apache.flink.core.io; +import org.apache.flink.annotation.PublicEvolving; + /** * This interface is implemented by classes that provide a version number. Versions numbers can be used to differentiate * between evolving classes. */ +@PublicEvolving public interface Versioned { /** http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java b/flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java index 94c2722..31d570c 100644 --- a/flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java +++ b/flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java @@ -18,6 +18,7 @@ package org.apache.flink.core.io; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -28,6 +29,7 @@ import java.io.IOException; * versions. Concrete subclasses should typically override the {@link #write(DataOutputView)} and * {@link #read(DataInputView)}, thereby calling super to ensure version checking. */ +@PublicEvolving public abstract class VersionedIOReadableWritable implements IOReadableWritable, Versioned { @Override @@ -67,4 +69,4 @@ public abstract class VersionedIOReadableWritable implements IOReadableWritable, public boolean isCompatibleVersion(int version) { return getVersion() == version; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/migration/util/MigrationInstantiationUtil.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/migration/util/MigrationInstantiationUtil.java b/flink-core/src/main/java/org/apache/flink/migration/util/MigrationInstantiationUtil.java index d175b2f..69e4e6d 100644 --- a/flink-core/src/main/java/org/apache/flink/migration/util/MigrationInstantiationUtil.java +++ b/flink-core/src/main/java/org/apache/flink/migration/util/MigrationInstantiationUtil.java @@ -18,6 +18,7 @@ package org.apache.flink.migration.util; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.util.InstantiationUtil; import java.io.ByteArrayInputStream; @@ -29,6 +30,7 @@ import java.io.ObjectStreamClass; /** * Utility class to deserialize legacy classes for migration. */ +@PublicEvolving public final class MigrationInstantiationUtil { public static class ClassLoaderObjectInputStream extends InstantiationUtil.ClassLoaderObjectInputStream { @@ -91,4 +93,4 @@ public final class MigrationInstantiationUtil { throw new IllegalAccessError(); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/flink/blob/0aa9918c/flink-core/src/main/java/org/apache/flink/migration/util/SerializedValue.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/migration/util/SerializedValue.java b/flink-core/src/main/java/org/apache/flink/migration/util/SerializedValue.java index aab68c9..bd40b83 100644 --- a/flink-core/src/main/java/org/apache/flink/migration/util/SerializedValue.java +++ b/flink-core/src/main/java/org/apache/flink/migration/util/SerializedValue.java @@ -18,6 +18,7 @@ package org.apache.flink.migration.util; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.util.InstantiationUtil; import java.io.IOException; @@ -36,6 +37,7 @@ import java.util.Arrays; * @param <T> The type of the value held. */ @Deprecated +@PublicEvolving public class SerializedValue<T> implements java.io.Serializable { private static final long serialVersionUID = -3564011643393683761L;
