Return-Path: X-Original-To: apmail-flink-commits-archive@minotaur.apache.org Delivered-To: apmail-flink-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7851218FB7 for ; Sun, 14 Feb 2016 21:54:38 +0000 (UTC) Received: (qmail 41466 invoked by uid 500); 14 Feb 2016 21:54:38 -0000 Delivered-To: apmail-flink-commits-archive@flink.apache.org Received: (qmail 41377 invoked by uid 500); 14 Feb 2016 21:54:38 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 41292 invoked by uid 99); 14 Feb 2016 21:54:38 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 14 Feb 2016 21:54:38 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 162D3E1126; Sun, 14 Feb 2016 21:54:38 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: fhueske@apache.org To: commits@flink.apache.org Date: Sun, 14 Feb 2016 21:54:40 -0000 Message-Id: <0e31c5a231c5435b83eeedd049d122de@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [3/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-core http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java index 6386fc1..371200c 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BooleanPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for boolean arrays. */ +@Internal public final class BooleanPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java index d914c3e..c76bcf2 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.ByteComparator; +@Internal public class BytePrimitiveArrayComparator extends PrimitiveArrayComparator { public BytePrimitiveArrayComparator(boolean ascending) { super(ascending, new ByteComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArraySerializer.java index ea4c43e..0f56149 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/BytePrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for byte arrays. */ +@Internal public final class BytePrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java index d734152..c9de7cc 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.CharComparator; +@Internal public class CharPrimitiveArrayComparator extends PrimitiveArrayComparator { public CharPrimitiveArrayComparator(boolean ascending) { super(ascending, new CharComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArraySerializer.java index e2f7515..c3655e9 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/CharPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for char arrays. */ +@Internal public final class CharPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArrayComparator.java index 5153fa5..675bac7 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.DoubleComparator; +@Internal public class DoublePrimitiveArrayComparator extends PrimitiveArrayComparator { public DoublePrimitiveArrayComparator(boolean ascending) { super(ascending, new DoubleComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArraySerializer.java index 2500312..2b07cfd 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/DoublePrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for double arrays. */ +@Internal public final class DoublePrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArrayComparator.java index 5a5986e..b77ab35 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.FloatComparator; +@Internal public class FloatPrimitiveArrayComparator extends PrimitiveArrayComparator { public FloatPrimitiveArrayComparator(boolean ascending) { super(ascending, new FloatComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArraySerializer.java index ea2513e..1fa4715 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/FloatPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for float arrays. */ +@Internal public final class FloatPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java index 78cb2ae..341154f 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.IntComparator; +@Internal public class IntPrimitiveArrayComparator extends PrimitiveArrayComparator { public IntPrimitiveArrayComparator(boolean ascending) { super(ascending, new IntComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArraySerializer.java index 05d70c5..a5a3e56 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/IntPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for int arrays. */ +@Internal public class IntPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArrayComparator.java index c0a69bc..9240fcd 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.LongComparator; +@Internal public class LongPrimitiveArrayComparator extends PrimitiveArrayComparator { public LongPrimitiveArrayComparator(boolean ascending) { super(ascending, new LongComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArraySerializer.java index e6f6cc5..3ecae36 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/LongPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for long arrays. */ +@Internal public final class LongPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java index ba53aff..5699f80 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java @@ -19,12 +19,15 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.BasicTypeComparator; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; import org.apache.flink.core.memory.MemorySegment; +@Internal public abstract class PrimitiveArrayComparator extends TypeComparator { // For use by getComparators @SuppressWarnings("rawtypes") http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java index 5943694..3a7e574 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArrayComparator.java @@ -18,9 +18,12 @@ package org.apache.flink.api.common.typeutils.base.array; import static java.lang.Math.min; + +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeComparator; import org.apache.flink.api.common.typeutils.base.ShortComparator; +@Internal public class ShortPrimitiveArrayComparator extends PrimitiveArrayComparator { public ShortPrimitiveArrayComparator(boolean ascending) { super(ascending, new ShortComparator(ascending)); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArraySerializer.java index e2261e8..7f542c3 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/ShortPrimitiveArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -27,6 +28,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A serializer for short arrays. */ +@Internal public final class ShortPrimitiveArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/StringArraySerializer.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/StringArraySerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/StringArraySerializer.java index 228429d..642cc1c 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/StringArraySerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/StringArraySerializer.java @@ -20,6 +20,7 @@ package org.apache.flink.api.common.typeutils.base.array; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -29,6 +30,7 @@ import org.apache.flink.types.StringValue; /** * A serializer for String arrays. Specialized for efficiency. */ +@Internal public final class StringArraySerializer extends TypeSerializerSingleton{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java index 1b008c0..c37fc77 100644 --- a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java +++ b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java @@ -26,11 +26,13 @@ import java.lang.reflect.Field; import java.util.Objects; import com.google.common.base.Preconditions; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeinfo.TypeInformation; /** * Represent a field definition for {@link PojoTypeInfo} type of objects. */ +@Internal public class PojoField implements Serializable { private static final long serialVersionUID = 1975295846436559363L; @@ -105,4 +107,4 @@ public class PojoField implements Serializable { public boolean canEqual(Object obj) { return obj instanceof PojoField; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java index faf5646..50c46e4 100644 --- a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java +++ b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java @@ -20,6 +20,7 @@ package org.apache.flink.api.java.typeutils.runtime; import com.esotericsoftware.kryo.Kryo; import com.esotericsoftware.kryo.KryoException; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.util.InstantiationUtil; @@ -28,6 +29,7 @@ import java.io.IOException; /** * Convenience methods for Kryo */ +@Internal public class KryoUtils { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/Serializers.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/Serializers.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/Serializers.java index 009cb24..b6e978f 100644 --- a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/Serializers.java +++ b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/Serializers.java @@ -28,6 +28,7 @@ import org.apache.avro.Schema; import org.apache.avro.generic.GenericData; import org.apache.avro.specific.SpecificRecordBase; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.api.common.typeutils.CompositeType; @@ -56,6 +57,7 @@ import java.util.Set; * to provide custom serialization for their classes. * Also, there is a Java Annotation for adding a default serializer (@DefaultSerializer) to classes. */ +@Internal public class Serializers { public static void recursivelyRegisterType(TypeInformation typeInfo, ExecutionConfig config, Set> alreadySeen) { http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java b/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java index 7d40dbc..7e50486 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java @@ -28,6 +28,7 @@ import java.io.InputStreamReader; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; +import org.apache.flink.annotation.Internal; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.w3c.dom.Document; @@ -40,6 +41,7 @@ import org.w3c.dom.Text; * Global configuration object for Flink. Similar to Java properties configuration * objects it includes key-value pairs which represent the framework's configuration. */ +@Internal public final class GlobalConfiguration { /** The log object used for debugging. */ http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java b/flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java index e6a2022..fcc77e0 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java @@ -18,12 +18,15 @@ package org.apache.flink.configuration; +import org.apache.flink.annotation.PublicEvolving; + /** * An {@code IllegalConfigurationException} is thrown when * the values in a given {@link Configuration} are not valid. This may refer * to the Flink configuration with which the framework is started, * or a Configuration passed internally between components. */ +@PublicEvolving public class IllegalConfigurationException extends RuntimeException { private static final long serialVersionUID = 695506964810499989L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/HadoopFileSystemWrapper.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/HadoopFileSystemWrapper.java b/flink-core/src/main/java/org/apache/flink/core/fs/HadoopFileSystemWrapper.java index 5f740c7..5a48e68 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/HadoopFileSystemWrapper.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/HadoopFileSystemWrapper.java @@ -17,6 +17,9 @@ */ package org.apache.flink.core.fs; +import org.apache.flink.annotation.PublicEvolving; + +@PublicEvolving public interface HadoopFileSystemWrapper { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalBlockLocation.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalBlockLocation.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalBlockLocation.java index 675e032..fa3de66 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalBlockLocation.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalBlockLocation.java @@ -21,6 +21,7 @@ package org.apache.flink.core.fs.local; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.core.fs.BlockLocation; /** @@ -28,6 +29,7 @@ import org.apache.flink.core.fs.BlockLocation; * local file system. * */ +@Internal public class LocalBlockLocation implements BlockLocation { private final long length; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataInputStream.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataInputStream.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataInputStream.java index 0d5fcf2..99ca2c4 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataInputStream.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataInputStream.java @@ -23,6 +23,7 @@ import java.io.File; import java.io.FileInputStream; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.core.fs.FSDataInputStream; /** @@ -30,6 +31,7 @@ import org.apache.flink.core.fs.FSDataInputStream; * input stream to the local file system. * */ +@Internal public class LocalDataInputStream extends FSDataInputStream { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java index ea1ca34..54ec8dd 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalDataOutputStream.java @@ -23,12 +23,14 @@ import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; +import org.apache.flink.annotation.Internal; import org.apache.flink.core.fs.FSDataOutputStream; /** * The LocalDataOutputStream class is a wrapper class for a data * output stream to the local file system. */ +@Internal public class LocalDataOutputStream extends FSDataOutputStream { private static final int MAX_OPEN_TRIES = 3; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileStatus.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileStatus.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileStatus.java index 9f9d5f0..0aebd75 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileStatus.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileStatus.java @@ -21,6 +21,7 @@ package org.apache.flink.core.fs.local; import java.io.File; +import org.apache.flink.annotation.Internal; import org.apache.flink.core.fs.FileStatus; import org.apache.flink.core.fs.FileSystem; import org.apache.flink.core.fs.Path; @@ -30,6 +31,7 @@ import org.apache.flink.core.fs.Path; * for the local file system. * */ +@Internal public class LocalFileStatus implements FileStatus { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java index 9dd9e30..3aaa85f 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java @@ -32,6 +32,7 @@ import java.net.InetAddress; import java.net.URI; import java.net.UnknownHostException; +import org.apache.flink.annotation.Internal; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.flink.core.fs.BlockLocation; @@ -47,6 +48,7 @@ import org.apache.flink.util.OperatingSystem; * system. * */ +@Internal public class LocalFileSystem extends FileSystem { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.java b/flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.java index cccb03f..a17dfbe 100644 --- a/flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.java +++ b/flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.java @@ -19,10 +19,13 @@ package org.apache.flink.core.io; +import org.apache.flink.annotation.PublicEvolving; + /** * An input split assigner distributes the {@link InputSplit}s among the instances on which a * data source exists. */ +@PublicEvolving public interface InputSplitAssigner { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java b/flink-core/src/main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java index d5664c9..19eb285 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.PublicEvolving; + import java.io.DataInputStream; import java.io.EOFException; import java.io.IOException; @@ -26,6 +28,7 @@ import java.io.InputStream; /** * Utility class that turns an {@link InputStream} into a {@link DataInputView}. */ +@PublicEvolving public class DataInputViewStreamWrapper extends DataInputStream implements DataInputView { public DataInputViewStreamWrapper(InputStream in) { http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/DataOutputViewStreamWrapper.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/DataOutputViewStreamWrapper.java b/flink-core/src/main/java/org/apache/flink/core/memory/DataOutputViewStreamWrapper.java index 61ad54e..9ec9c29 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/DataOutputViewStreamWrapper.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/DataOutputViewStreamWrapper.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.PublicEvolving; + import java.io.DataOutputStream; import java.io.IOException; import java.io.OutputStream; @@ -25,6 +27,7 @@ import java.io.OutputStream; /** * Utility class that turns an {@link OutputStream} into a {@link DataOutputView}. */ +@PublicEvolving public class DataOutputViewStreamWrapper extends DataOutputStream implements DataOutputView { private byte[] tempBuffer; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/HeapMemorySegment.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/HeapMemorySegment.java b/flink-core/src/main/java/org/apache/flink/core/memory/HeapMemorySegment.java index 0685d59..d136404 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/HeapMemorySegment.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/HeapMemorySegment.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; @@ -35,6 +37,7 @@ import java.util.Objects; * Note that memory segments should usually not be allocated manually, but rather through the * {@link MemorySegmentFactory}. */ +@Internal public final class HeapMemorySegment extends MemorySegment { /** An extra reference to the heap memory, so we can let byte array checks fail http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java b/flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java index f68723b..1fe37ee 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; @@ -39,6 +41,7 @@ import java.nio.ByteBuffer; * Note that memory segments should usually not be allocated manually, but rather through the * {@link MemorySegmentFactory}. */ +@Internal public final class HybridMemorySegment extends MemorySegment { /** The direct byte buffer that allocated the off-heap memory. This memory segment holds a reference http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java index 8d13921..af3efe7 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; @@ -90,6 +92,7 @@ import java.nio.ByteOrder; * or by identifying that the invocations are monomorphic (all go to the same concrete * method implementation). Under these conditions, the JIT can perfectly inline methods. */ +@Internal public abstract class MemorySegment { /** The unsafe handle for transparent memory copied (heap / off-heap) */ http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java index 0e4e469..882c37d 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java @@ -18,6 +18,8 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + import java.nio.ByteBuffer; /** @@ -29,6 +31,7 @@ import java.nio.ByteBuffer; * Note that this factory auto-initialized to use {@link org.apache.flink.core.memory.HeapMemorySegment}, * if a request to create a segment comes before the initialization. */ +@Internal public class MemorySegmentFactory { /** The factory to use */ http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentSource.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentSource.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentSource.java index fc0805c..8ae8299 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentSource.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentSource.java @@ -18,9 +18,12 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + /** * Interface describing entities that can provide memory segments. */ +@Internal public interface MemorySegmentSource { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java index 5b2b5d3..804f00d 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java @@ -18,9 +18,12 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + /** * The class of memory, such as heap or off-heap. */ +@Internal public enum MemoryType { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java b/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java index 20b37c9..b3a04cb 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java @@ -18,12 +18,15 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.Internal; + import java.lang.reflect.Field; import java.nio.ByteOrder; /** * Utility class for memory operations. */ +@Internal public class MemoryUtils { /** The "unsafe", which can be used to perform native memory accesses. */ http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataInputView.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataInputView.java b/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataInputView.java index 4b91360..2c048de 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataInputView.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataInputView.java @@ -19,10 +19,13 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.PublicEvolving; + /** * Interface marking a {@link DataInputView} as seekable. Seekable views can set the position where they * read from. */ +@PublicEvolving public interface SeekableDataInputView extends DataInputView { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataOutputView.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataOutputView.java b/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataOutputView.java index 4e48a8b..967cefe 100644 --- a/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataOutputView.java +++ b/flink-core/src/main/java/org/apache/flink/core/memory/SeekableDataOutputView.java @@ -19,10 +19,13 @@ package org.apache.flink.core.memory; +import org.apache.flink.annotation.PublicEvolving; + /** * Interface marking a {@link DataOutputView} as seekable. Seekable views can set the position where they * write to. */ +@PublicEvolving public interface SeekableDataOutputView extends DataOutputView { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/JavaToValueConverter.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/JavaToValueConverter.java b/flink-core/src/main/java/org/apache/flink/types/JavaToValueConverter.java index 0a848c4..e564595 100644 --- a/flink-core/src/main/java/org/apache/flink/types/JavaToValueConverter.java +++ b/flink-core/src/main/java/org/apache/flink/types/JavaToValueConverter.java @@ -18,6 +18,9 @@ package org.apache.flink.types; +import org.apache.flink.annotation.PublicEvolving; + +@PublicEvolving public class JavaToValueConverter { public static Value convertBoxedJavaType(Object boxed) { http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/Key.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/Key.java b/flink-core/src/main/java/org/apache/flink/types/Key.java index cc1978c..c1e0626 100644 --- a/flink-core/src/main/java/org/apache/flink/types/Key.java +++ b/flink-core/src/main/java/org/apache/flink/types/Key.java @@ -18,6 +18,8 @@ package org.apache.flink.types; +import org.apache.flink.annotation.PublicEvolving; + /** * This interface has to be implemented by all data types that act as key. Keys are used to establish * relationships between values. A key must always be {@link java.lang.Comparable} to other keys of @@ -35,6 +37,7 @@ package org.apache.flink.types; * in future versions as well. */ @Deprecated +@PublicEvolving public interface Key extends Value, Comparable { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/NullKeyFieldException.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/NullKeyFieldException.java b/flink-core/src/main/java/org/apache/flink/types/NullKeyFieldException.java index 18a98a3..6edba1e 100644 --- a/flink-core/src/main/java/org/apache/flink/types/NullKeyFieldException.java +++ b/flink-core/src/main/java/org/apache/flink/types/NullKeyFieldException.java @@ -18,9 +18,12 @@ package org.apache.flink.types; +import org.apache.flink.annotation.Public; + /** * An exception specifying that a required key field was not set in a record, i.e. was null. */ +@Public public class NullKeyFieldException extends RuntimeException { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/Pair.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/Pair.java b/flink-core/src/main/java/org/apache/flink/types/Pair.java index fdd26ba..9bf2387 100644 --- a/flink-core/src/main/java/org/apache/flink/types/Pair.java +++ b/flink-core/src/main/java/org/apache/flink/types/Pair.java @@ -21,6 +21,7 @@ package org.apache.flink.types; import java.io.IOException; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; import org.apache.flink.util.ReflectionUtil; @@ -33,6 +34,7 @@ import org.apache.flink.util.ReflectionUtil; * @param Type of the pair's first element. * @param Type of the pair's second element. */ +@PublicEvolving public abstract class Pair, V extends Key> implements Key> { private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java index 58bd1d2..90fa41e 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java @@ -18,6 +18,9 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + +@PublicEvolving public class BooleanParser extends FieldParser { private boolean result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java index d4ffafb..a90c198 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java @@ -18,8 +18,10 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.BooleanValue; +@PublicEvolving public class BooleanValueParser extends FieldParser { private BooleanParser parser = new BooleanParser(); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java index 9810fea..a521ac1 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java @@ -19,7 +19,9 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; +@PublicEvolving public class ByteParser extends FieldParser { private byte result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/ByteValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/ByteValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/ByteValueParser.java index 612a1cb..416a498 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/ByteValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/ByteValueParser.java @@ -19,12 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.ByteValue; /** * Parses a decimal text field into a {@link ByteValue}. * Only characters '1' to '0' and '-' are allowed. */ +@PublicEvolving public class ByteValueParser extends FieldParser { private ByteValue result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java index 17bb028..0b2f5a2 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java @@ -19,9 +19,12 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Parses a text field into a Double. */ +@PublicEvolving public class DoubleParser extends FieldParser { private static final Double DOUBLE_INSTANCE = Double.valueOf(0.0); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/DoubleValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/DoubleValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/DoubleValueParser.java index 5a1199a..333e6c9 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/DoubleValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/DoubleValueParser.java @@ -19,11 +19,13 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.DoubleValue; /** * Parses a text field into a DoubleValue. */ +@PublicEvolving public class DoubleValueParser extends FieldParser { private DoubleValue result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java index faf1adb..57689a8 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java @@ -22,6 +22,7 @@ package org.apache.flink.types.parser; import java.util.HashMap; import java.util.Map; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.BooleanValue; import org.apache.flink.types.ByteValue; import org.apache.flink.types.DoubleValue; @@ -40,6 +41,7 @@ import org.apache.flink.types.StringValue; * * @param The type that is parsed. */ +@PublicEvolving public abstract class FieldParser { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java index 5868632..a47877e 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java @@ -19,9 +19,12 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Parses a text field into a {@link Float}. */ +@PublicEvolving public class FloatParser extends FieldParser { private float result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/FloatValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/FloatValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/FloatValueParser.java index 3e17823..b6da3d3 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/FloatValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/FloatValueParser.java @@ -19,11 +19,13 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.FloatValue; /** * Parses a text field into a {@link FloatValue} */ +@PublicEvolving public class FloatValueParser extends FieldParser { private FloatValue result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java index 8a40055..4d2ae7c 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java @@ -19,11 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Parses a decimal text field into a IntValue. * Only characters '1' to '0' and '-' are allowed. * The parser does not check for the maximum value. */ +@PublicEvolving public class IntParser extends FieldParser { private static final long OVERFLOW_BOUND = 0x7fffffffL; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/IntValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/IntValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/IntValueParser.java index abd8615..d493e2d 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/IntValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/IntValueParser.java @@ -19,12 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.IntValue; /** * Parses a decimal text field into a IntValue. * Only characters '1' to '0' and '-' are allowed. */ +@PublicEvolving public class IntValueParser extends FieldParser { private static final long OVERFLOW_BOUND = 0x7fffffffL; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java index 556274b..e8ac09b 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java @@ -19,10 +19,13 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Parses a decimal text field into a LongValue. * Only characters '1' to '0' and '-' are allowed. */ +@PublicEvolving public class LongParser extends FieldParser { private long result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/LongValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/LongValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/LongValueParser.java index a99a86e..eaaf619 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/LongValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/LongValueParser.java @@ -19,12 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.LongValue; /** * Parses a decimal text field into a LongValue. * Only characters '1' to '0' and '-' are allowed. */ +@PublicEvolving public class LongValueParser extends FieldParser { private LongValue result; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java index 32df214..6f1fc7b 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java @@ -19,11 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Parses a decimal text field into a {@link Short}. * Only characters '1' to '0' and '-' are allowed. * The parser does not check for the maximum value. */ +@PublicEvolving public class ShortParser extends FieldParser { private static final int OVERFLOW_BOUND = 0x7fff; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/ShortValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/ShortValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/ShortValueParser.java index 4289d1a..c1df9ce 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/ShortValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/ShortValueParser.java @@ -19,12 +19,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.ShortValue; /** * Parses a decimal text field into a {@link ShortValue}. * Only characters '1' to '0' and '-' are allowed. */ +@PublicEvolving public class ShortValueParser extends FieldParser { private static final int OVERFLOW_BOUND = 0x7fff; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/StringParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/StringParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/StringParser.java index 47e4494..7dc80e5 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/StringParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/StringParser.java @@ -18,11 +18,14 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; + /** * Converts a variable length field of a byte array into a {@link String}. The byte contents between * delimiters is interpreted as an ASCII string. The string may be quoted in double quotes. For quoted * strings, whitespaces (space and tab) leading and trailing before and after the quotes are removed. */ +@PublicEvolving public class StringParser extends FieldParser { private boolean quotedStringParsing = false; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/types/parser/StringValueParser.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/types/parser/StringValueParser.java b/flink-core/src/main/java/org/apache/flink/types/parser/StringValueParser.java index bcb1042..586c2cc 100644 --- a/flink-core/src/main/java/org/apache/flink/types/parser/StringValueParser.java +++ b/flink-core/src/main/java/org/apache/flink/types/parser/StringValueParser.java @@ -18,6 +18,7 @@ package org.apache.flink.types.parser; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.types.StringValue; /** @@ -27,6 +28,7 @@ import org.apache.flink.types.StringValue; * * @see StringValue */ +@PublicEvolving public class StringValueParser extends FieldParser { private boolean quotedStringParsing = false; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/AbstractID.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/AbstractID.java b/flink-core/src/main/java/org/apache/flink/util/AbstractID.java index 27276af..c35e220 100644 --- a/flink-core/src/main/java/org/apache/flink/util/AbstractID.java +++ b/flink-core/src/main/java/org/apache/flink/util/AbstractID.java @@ -21,6 +21,7 @@ package org.apache.flink.util; import java.io.IOException; import java.util.Random; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.core.io.IOReadableWritable; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; @@ -28,6 +29,7 @@ import org.apache.flink.core.memory.DataOutputView; /** * A statistically unique identification number. */ +@PublicEvolving public class AbstractID implements IOReadableWritable, Comparable, java.io.Serializable { private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java b/flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java index 092e2ba..b3c78f8 100644 --- a/flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java +++ b/flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java @@ -24,10 +24,13 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.io.IOException; import java.io.PrintWriter; import java.io.StringWriter; +@Internal public final class ExceptionUtils { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/ExternalProcessRunner.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/ExternalProcessRunner.java b/flink-core/src/main/java/org/apache/flink/util/ExternalProcessRunner.java index b7e388c..207278e 100644 --- a/flink-core/src/main/java/org/apache/flink/util/ExternalProcessRunner.java +++ b/flink-core/src/main/java/org/apache/flink/util/ExternalProcessRunner.java @@ -17,6 +17,8 @@ */ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.io.File; import java.io.IOException; import java.io.InputStream; @@ -36,6 +38,7 @@ import java.util.List; *

Attention: The entry point class must be in the classpath of the currently running process, * otherwise the newly spawned process will not find it and fail. */ +@Internal public class ExternalProcessRunner { private final String entryPointClassName; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java b/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java index e2439ca..bd068f3 100644 --- a/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java +++ b/flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java @@ -18,6 +18,7 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.configuration.Configuration; import org.apache.flink.core.memory.DataInputViewStreamWrapper; @@ -38,6 +39,7 @@ import java.util.HashMap; /** * Utility class to create instances from class objects and checking failure reasons. */ +@Internal public final class InstantiationUtil { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/IterableIterator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/IterableIterator.java b/flink-core/src/main/java/org/apache/flink/util/IterableIterator.java index e0356fa..f66bab9 100644 --- a/flink-core/src/main/java/org/apache/flink/util/IterableIterator.java +++ b/flink-core/src/main/java/org/apache/flink/util/IterableIterator.java @@ -19,6 +19,8 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.util.Iterator; /** @@ -26,5 +28,6 @@ import java.util.Iterator; * * @param The iterated elements' type. */ +@Internal public interface IterableIterator extends Iterator, Iterable { } http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/MavenForkNumberPrefixLayout.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/MavenForkNumberPrefixLayout.java b/flink-core/src/main/java/org/apache/flink/util/MavenForkNumberPrefixLayout.java index 8d16458..c6f9012 100644 --- a/flink-core/src/main/java/org/apache/flink/util/MavenForkNumberPrefixLayout.java +++ b/flink-core/src/main/java/org/apache/flink/util/MavenForkNumberPrefixLayout.java @@ -18,6 +18,7 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; import org.apache.log4j.PatternLayout; import org.apache.log4j.spi.LoggingEvent; @@ -27,6 +28,7 @@ import org.apache.log4j.spi.LoggingEvent; * Use this layout when running tests via Maven in parallel and logging to the Console. When logging * to a file, you can use a separate file for each fork. */ +@Internal public class MavenForkNumberPrefixLayout extends PatternLayout { /** Property name used to set fork number of the forked JVM. */ http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/MutableObjectIterator.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/MutableObjectIterator.java b/flink-core/src/main/java/org/apache/flink/util/MutableObjectIterator.java index d0d393e..9273330 100644 --- a/flink-core/src/main/java/org/apache/flink/util/MutableObjectIterator.java +++ b/flink-core/src/main/java/org/apache/flink/util/MutableObjectIterator.java @@ -17,6 +17,8 @@ */ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.io.IOException; /** @@ -32,6 +34,7 @@ import java.io.IOException; * * @param The element type of the collection iterated over. */ +@Internal public interface MutableObjectIterator { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/NetUtils.java b/flink-core/src/main/java/org/apache/flink/util/NetUtils.java index cdb54ed..e7a957b 100644 --- a/flink-core/src/main/java/org/apache/flink/util/NetUtils.java +++ b/flink-core/src/main/java/org/apache/flink/util/NetUtils.java @@ -20,6 +20,7 @@ package org.apache.flink.util; import com.google.common.collect.Iterators; import com.google.common.net.InetAddresses; +import org.apache.flink.annotation.Internal; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -36,6 +37,7 @@ import java.util.ArrayList; import java.util.Iterator; import java.util.List; +@Internal public class NetUtils { private static final Logger LOG = LoggerFactory.getLogger(NetUtils.class); http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/OperatingSystem.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/OperatingSystem.java b/flink-core/src/main/java/org/apache/flink/util/OperatingSystem.java index eed1fc9..4dc3abb 100644 --- a/flink-core/src/main/java/org/apache/flink/util/OperatingSystem.java +++ b/flink-core/src/main/java/org/apache/flink/util/OperatingSystem.java @@ -18,9 +18,12 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + /** * An enumeration indicating the operating system that the JVM runs on. */ +@Internal public enum OperatingSystem { LINUX, http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/ReflectionUtil.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/ReflectionUtil.java b/flink-core/src/main/java/org/apache/flink/util/ReflectionUtil.java index 94c7db4..fe2d4c0 100644 --- a/flink-core/src/main/java/org/apache/flink/util/ReflectionUtil.java +++ b/flink-core/src/main/java/org/apache/flink/util/ReflectionUtil.java @@ -19,9 +19,12 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; +@Internal public final class ReflectionUtil { public static T newInstance(Class clazz) { try { http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/SerializedValue.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/SerializedValue.java b/flink-core/src/main/java/org/apache/flink/util/SerializedValue.java index 504e458..7bc0f09 100644 --- a/flink-core/src/main/java/org/apache/flink/util/SerializedValue.java +++ b/flink-core/src/main/java/org/apache/flink/util/SerializedValue.java @@ -18,6 +18,8 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + import java.io.IOException; import java.util.Arrays; @@ -33,6 +35,7 @@ import java.util.Arrays; * * @param The type of the value held. */ +@Internal public class SerializedValue implements java.io.Serializable { private static final long serialVersionUID = -3564011643393683761L; http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/SimpleStringUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/SimpleStringUtils.java b/flink-core/src/main/java/org/apache/flink/util/SimpleStringUtils.java index 609a015..43a93eb 100644 --- a/flink-core/src/main/java/org/apache/flink/util/SimpleStringUtils.java +++ b/flink-core/src/main/java/org/apache/flink/util/SimpleStringUtils.java @@ -20,6 +20,7 @@ package org.apache.flink.util; import java.io.Serializable; +import org.apache.flink.annotation.Internal; import org.apache.flink.types.StringValue; /** @@ -27,6 +28,7 @@ import org.apache.flink.types.StringValue; * written to be optimized for efficiency and work only on strings whose characters are * representable in a single char, ie. strings without surrogate characters. */ +@Internal public final class SimpleStringUtils { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/StringUtils.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/StringUtils.java b/flink-core/src/main/java/org/apache/flink/util/StringUtils.java index 2257183..10b6304 100644 --- a/flink-core/src/main/java/org/apache/flink/util/StringUtils.java +++ b/flink-core/src/main/java/org/apache/flink/util/StringUtils.java @@ -22,6 +22,7 @@ import java.io.IOException; import java.util.Arrays; import java.util.Random; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; import org.apache.flink.types.StringValue; @@ -29,6 +30,7 @@ import org.apache.flink.types.StringValue; /** * Utility class to convert objects into strings in vice-versa. */ +@PublicEvolving public final class StringUtils { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/Visitable.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/Visitable.java b/flink-core/src/main/java/org/apache/flink/util/Visitable.java index 559cb96..4df6b6e 100644 --- a/flink-core/src/main/java/org/apache/flink/util/Visitable.java +++ b/flink-core/src/main/java/org/apache/flink/util/Visitable.java @@ -19,6 +19,8 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + /** * This interface marks types as visitable during a traversal. The central method accept(...) contains the logic * about how to invoke the supplied {@link Visitor} on the visitable object, and how to traverse further. @@ -30,6 +32,7 @@ package org.apache.flink.util; * * @see Visitor */ +@Internal public interface Visitable> { /** http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/util/Visitor.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/util/Visitor.java b/flink-core/src/main/java/org/apache/flink/util/Visitor.java index d7a07ac..2cc68fc 100644 --- a/flink-core/src/main/java/org/apache/flink/util/Visitor.java +++ b/flink-core/src/main/java/org/apache/flink/util/Visitor.java @@ -19,9 +19,12 @@ package org.apache.flink.util; +import org.apache.flink.annotation.Internal; + /** * A visitor encapsulates functionality that is applied to each node in the process of a traversal of a tree or DAD. */ +@Internal public interface Visitor> { /**