You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/02/20 00:55:21 UTC
[07/19] flink git commit: [hotfix] [core] Add missing @PublicEvolving
annotations to classes in flink-core.
[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 <fh...@apache.org>
Authored: Wed Feb 15 15:25:01 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
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;