flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [flink-core] Added the member currentSplit to FileInputFormat. This member contains the split that this parallel instance must consume.
Date Sun, 07 Jun 2015 21:49:28 GMT
Repository: flink
Updated Branches:
  refs/heads/master 4fa3c0bf2 -> 868b62b76


[flink-core] Added the member currentSplit to FileInputFormat. This member contains the split
that this parallel instance must consume.

This closes #791


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

Branch: refs/heads/master
Commit: 868b62b76e31550b3023195658b6bb2c66b670cc
Parents: 4fa3c0b
Author: Peter Schrott <peter.schrott89@gmail.com>
Authored: Fri Jun 5 10:37:26 2015 +0200
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Sun Jun 7 23:48:43 2015 +0200

----------------------------------------------------------------------
 .../org/apache/flink/api/common/io/FileInputFormat.java     | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/868b62b7/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
index a8f334b..cdc408d 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
@@ -120,7 +120,11 @@ public abstract class FileInputFormat<OT> implements InputFormat<OT,
FileInputSp
 	 * The length of the split that this parallel instance must consume.
 	 */
 	protected transient long splitLength;
-	
+
+	/**
+	 * The current split that this parallel instance must consume.
+	 */
+	protected transient FileInputSplit currentSplit;
 	
 	// --------------------------------------------------------------------------------------------
 	//  The configuration parameters. Configured on the instance and serialized to be shipped.
@@ -588,7 +592,8 @@ public abstract class FileInputFormat<OT> implements InputFormat<OT,
FileInputSp
 	 */
 	@Override
 	public void open(FileInputSplit fileSplit) throws IOException {
-		
+
+		this.currentSplit = fileSplit;
 		this.splitStart = fileSplit.getStart();
 		this.splitLength = fileSplit.getLength();
 


Mime
View raw message