GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/832
[FLINK-2152] Added zipWithIndex
This PR adds the zipWithIndex utility method to Flink's DataSetUtils as
described in the mailing list discussion:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/The-correct-location-for-zipWithIndex-and-zipWithUniqueId-td6310.html.
The method could, in the future, be moved to DataSet.
@fhueske , @tillrohrmann , once we reach a conclusion for this one, I will
also update #801 (I wouldn't like to fix unnecessary merge conflicts).
Once zipWIthUniqueIds is added, I could also explain the difference in the
docs.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/andralungu/flink zipWithIndex
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/832.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 #832
----
commit fdbf0167cc10e952faddc2a7d71e73e7f1f2d03f
Author: andralungu <[email protected]>
Date: 2015-06-12T18:37:27Z
[FLINK-2152] zipWithIndex implementation
[FLINK-2152] Added zipWithIndex utility method
----
---
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.
---
