Repository: incubator-flink Updated Branches: refs/heads/master 4895131e8 -> 24c47362e
Remove full package name for FlatMapOperatorBase Simple code cleanup to remove full package name for FlatMapOperatorBase for FlatMapOperator#translateToDataFlow method Author: Henry Saputra <[email protected]> Closes #272 from hsaputra/remove_packagepath_flatmapoperatorbase and squashes the following commits: 8ce5abd [Henry Saputra] Remove full package name for FlatMapOperatorBase for FlatMapOperator#translateToDataFlow method. Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/24c47362 Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/24c47362 Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/24c47362 Branch: refs/heads/master Commit: 24c47362e716c1126b40f098d2326dc5c47cd699 Parents: 4895131 Author: Henry Saputra <[email protected]> Authored: Mon Jan 5 10:54:03 2015 -0800 Committer: Henry Saputra <[email protected]> Committed: Mon Jan 5 10:54:03 2015 -0800 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/operators/FlatMapOperator.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/24c47362/flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java b/flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java index 9fa7cf1..73d6095 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java @@ -47,8 +47,7 @@ public class FlatMapOperator<IN, OUT> extends SingleInputUdfOperator<IN, OUT, Fl } @Override - protected org.apache.flink.api.common.operators.base.FlatMapOperatorBase<IN, OUT, FlatMapFunction<IN,OUT>> translateToDataFlow(Operator<IN> input) { - + protected FlatMapOperatorBase<IN, OUT, FlatMapFunction<IN,OUT>> translateToDataFlow(Operator<IN> input) { String name = getName() != null ? getName() : "FlatMap at "+defaultName; // create operator FlatMapOperatorBase<IN, OUT, FlatMapFunction<IN, OUT>> po = new FlatMapOperatorBase<IN, OUT, FlatMapFunction<IN, OUT>>(function, new UnaryOperatorInformation<IN, OUT>(getInputType(), getResultType()), name);
