Repository: flink Updated Branches: refs/heads/master da991aebb -> 7d61e1f2f
[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/6346a899 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6346a899 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6346a899 Branch: refs/heads/master Commit: 6346a89972416489bc43ee30946078341496d1e1 Parents: da991ae Author: Greg Hogan <[email protected]> Authored: Wed Nov 2 11:02:51 2016 -0400 Committer: Fabian Hueske <[email protected]> Committed: Wed Nov 2 18:20:27 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/6346a899/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,
