From b6e97b9212f069100f1e19d632b821c4a7c50b8f Mon Sep 17 00:00:00 2001 From: Greg Hogan Date: Wed, 2 Nov 2016 11:02:51 -0400 Subject: [PATCH] [FLINK-4996] [core] Make CrossHint @Public --- .../api/common/operators/base/CrossOperatorBase.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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 95d5bc3049c29..72da53dc7762e 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.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