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 2016/09/20 12:05:37 UTC
flink git commit: [FLINK-4610] [core] Replace keySet/getValue with
entrySet in UdfAnalyzerUtils
Repository: flink
Updated Branches:
refs/heads/master 5066125f9 -> 5901bf33b
[FLINK-4610] [core] Replace keySet/getValue with entrySet in UdfAnalyzerUtils
This closes #2491
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5901bf33
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5901bf33
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5901bf33
Branch: refs/heads/master
Commit: 5901bf33bc38b2d0317d3322e26dd427c3319bef
Parents: 5066125
Author: Alexander Pivovarov <ap...@gmail.com>
Authored: Fri Sep 9 23:10:12 2016 -0700
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Sep 19 22:26:20 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/5901bf33/flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java b/flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java
index ca00d54..a477a03 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzerUtils.java
@@ -271,15 +271,15 @@ public final class UdfAnalyzerUtils {
}
// recursively merge contained mappings
- Iterator<String> it = resultMapping.keySet().iterator();
+ Iterator<Map.Entry<String, TaggedValue>> it = resultMapping.entrySet().iterator();
while (it.hasNext()) {
- String key = it.next();
- TaggedValue value = mergeReturnValues(Collections.singletonList(resultMapping.get(key)));
+ Map.Entry<String, TaggedValue> entry = it.next();
+ TaggedValue value = mergeReturnValues(Collections.singletonList(entry.getValue()));
if (value == null) {
it.remove();
}
else {
- resultMapping.put(key, value);
+ entry.setValue(value);
}
}