You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/08/29 20:27:30 UTC
git commit: [FLINK-1071] Add Map Partition to Plan dump JSON generator
Repository: incubator-flink
Updated Branches:
refs/heads/master 00840599a -> 1e38a636f
[FLINK-1071] Add Map Partition to Plan dump JSON generator
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/1e38a636
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/1e38a636
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/1e38a636
Branch: refs/heads/master
Commit: 1e38a636ffb52b19bbf820de1d26f539a2cc24be
Parents: 0084059
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Aug 29 20:26:01 2014 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Aug 29 20:26:01 2014 +0200
----------------------------------------------------------------------
.../flink/compiler/plandump/PlanJSONDumpGenerator.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/1e38a636/flink-compiler/src/main/java/org/apache/flink/compiler/plandump/PlanJSONDumpGenerator.java
----------------------------------------------------------------------
diff --git a/flink-compiler/src/main/java/org/apache/flink/compiler/plandump/PlanJSONDumpGenerator.java b/flink-compiler/src/main/java/org/apache/flink/compiler/plandump/PlanJSONDumpGenerator.java
index 0ca4fb7..ad8f92b 100644
--- a/flink-compiler/src/main/java/org/apache/flink/compiler/plandump/PlanJSONDumpGenerator.java
+++ b/flink-compiler/src/main/java/org/apache/flink/compiler/plandump/PlanJSONDumpGenerator.java
@@ -407,9 +407,16 @@ public class PlanJSONDumpGenerator {
case COLLECTOR_MAP:
case MAP:
- case FLAT_MAP:
locString = "Map";
break;
+
+ case FLAT_MAP:
+ locString = "FlatMap";
+ break;
+
+ case MAP_PARTITION:
+ locString = "Map Partition";
+ break;
case ALL_REDUCE:
locString = "Reduce All";
@@ -472,8 +479,8 @@ public class PlanJSONDumpGenerator {
break;
default:
- throw new CompilerException("Unknown local strategy '" + p.getDriverStrategy().name()
- + "' in JSON generator.");
+ locString = p.getDriverStrategy().name();
+ break;
}
if (locString != null) {