flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [3/5] git commit: Fix generic warning in Plan
Date Fri, 13 Jun 2014 00:00:34 GMT
Fix generic warning in Plan


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/09c4c05f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/09c4c05f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/09c4c05f

Branch: refs/heads/master
Commit: 09c4c05f065102d79f7b88f2ecb2c6ae7c093d4a
Parents: 5a6e2e7
Author: StephanEwen <stephan.ewen@tu-berlin.de>
Authored: Thu Jun 12 19:04:21 2014 +0200
Committer: StephanEwen <stephan.ewen@tu-berlin.de>
Committed: Fri Jun 13 00:53:35 2014 +0200

----------------------------------------------------------------------
 .../src/main/java/eu/stratosphere/api/common/Plan.java         | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/09c4c05f/stratosphere-core/src/main/java/eu/stratosphere/api/common/Plan.java
----------------------------------------------------------------------
diff --git a/stratosphere-core/src/main/java/eu/stratosphere/api/common/Plan.java b/stratosphere-core/src/main/java/eu/stratosphere/api/common/Plan.java
index dc3adb6..b6f5385 100644
--- a/stratosphere-core/src/main/java/eu/stratosphere/api/common/Plan.java
+++ b/stratosphere-core/src/main/java/eu/stratosphere/api/common/Plan.java
@@ -32,6 +32,7 @@ import eu.stratosphere.core.fs.FileSystem;
 import eu.stratosphere.core.fs.Path;
 import eu.stratosphere.util.Visitable;
 import eu.stratosphere.util.Visitor;
+
 import java.io.File;
 import java.io.IOException;
 import java.net.URI;
@@ -67,7 +68,10 @@ public class Plan implements Visitable<Operator<?>> {
 	 */
 	protected int maxNumberMachines;
 
-	protected HashMap<String, DistributedCacheEntry> cacheFile = new HashMap();
+	/**
+	 * Hash map for files in the distributed cache: registered name to cache entry.
+	 */
+	protected HashMap<String, DistributedCacheEntry> cacheFile = new HashMap<String,
DistributedCacheEntry>();
 
 	// ------------------------------------------------------------------------
 


Mime
View raw message