GitHub user peedeeX21 opened a pull request:
https://github.com/apache/flink/pull/791
Added member currentSplit for FileInputFormat.java
According to [this stackoverflow discussion]
(http://stackoverflow.com/questions/30599616/create-objects-from-input-files-in-apache-flink/30600148?noredirect=1#comment49358891_30600148)
with
@rmetzger the attribute currentSplit is now accessible through
FileInputFormat. It provides the split that this parallel instance must consume.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/peedeeX21/flink feature_fileinputformat
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/791.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #791
----
commit be8bd1cb71d0f5d82a2003e1b354e9db6591889c
Author: Peter Schrott <[email protected]>
Date: 2015-06-05T08:37:26Z
[flink-core] Added the member currentSplit to FileInputFormat. This member
contains the split that this parallel instance must consume.
commit 41e7f88c64ed3e0101958556c7bf4bdb7991f288
Author: Peter Schrott <[email protected]>
Date: 2015-06-05T08:39:15Z
Merge branch 'master' of github.com:apache/flink into
feature_fileinputformat
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
