You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/07/30 15:06:52 UTC

[2/2] flink git commit: [cascading] add getJobConf() to HadoopInputSplit

[cascading] add getJobConf() to HadoopInputSplit


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

Branch: refs/heads/master
Commit: 466f9bf9c98b05bf35ca29af1b04343b7c9ea5f6
Parents: 73af891
Author: Fabian Hueske <fh...@apache.org>
Authored: Fri Jul 17 00:31:09 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Thu Jul 30 15:06:06 2015 +0200

----------------------------------------------------------------------
 .../flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java   | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/466f9bf9/flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java b/flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java
index d949dfd..15f94b2 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java
@@ -80,6 +80,10 @@ public class HadoopInputSplit extends LocatableInputSplit {
 		return hadoopInputSplit;
 	}
 
+	public JobConf getJobConf() {
+		return this.jobConf;
+	}
+
 	// ------------------------------------------------------------------------
 	//  Serialization
 	// ------------------------------------------------------------------------