Repository: flink Updated Branches: refs/heads/release-1.1 8412234eb -> 6e57e7f46
[FLINK-4996] [core] Make CrossHint @Public This closes #2743. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e57e7f4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e57e7f4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6e57e7f4 Branch: refs/heads/release-1.1 Commit: 6e57e7f463873cc9a36c71e3edde91a724bd48a6 Parents: 8412234 Author: Greg Hogan <[email protected]> Authored: Wed Nov 2 11:02:51 2016 -0400 Committer: Fabian Hueske <[email protected]> Committed: Wed Nov 2 21:48:00 2016 +0100 ---------------------------------------------------------------------- .../flink/api/common/operators/base/CrossOperatorBase.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6e57e7f4/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java b/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java index 95d5bc3..72da53d 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java @@ -18,10 +18,8 @@ package org.apache.flink.api.common.operators.base; -import java.util.ArrayList; -import java.util.List; - import org.apache.flink.annotation.Internal; +import org.apache.flink.annotation.Public; import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.api.common.functions.CrossFunction; import org.apache.flink.api.common.functions.RuntimeContext; @@ -33,6 +31,9 @@ import org.apache.flink.api.common.operators.util.UserCodeObjectWrapper; import org.apache.flink.api.common.operators.util.UserCodeWrapper; import org.apache.flink.api.common.typeutils.TypeSerializer; +import java.util.ArrayList; +import java.util.List; + /** * @see org.apache.flink.api.common.functions.CrossFunction */ @@ -42,6 +43,7 @@ public class CrossOperatorBase<IN1, IN2, OUT, FT extends CrossFunction<IN1, IN2, /** * The cross hint tells the system which sizes to expect from the data sets */ + @Public public static enum CrossHint { OPTIMIZER_CHOOSES,
