You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/14 00:25:00 UTC
[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in
flink-contrib
[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584840#comment-14584840 ]
ASF GitHub Bot commented on FLINK-2152:
---------------------------------------
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 <lu...@gmail.com>
Date: 2015-06-12T18:37:27Z
[FLINK-2152] zipWithIndex implementation
[FLINK-2152] Added zipWithIndex utility method
----
> Provide zipWithIndex utility in flink-contrib
> ---------------------------------------------
>
> Key: FLINK-2152
> URL: https://issues.apache.org/jira/browse/FLINK-2152
> Project: Flink
> Issue Type: Improvement
> Components: Java API
> Reporter: Robert Metzger
> Assignee: Andra Lungu
> Priority: Trivial
> Labels: starter
>
> We should provide a simple utility method for zipping elements in a data set with a dense index.
> its up for discussion whether we want it directly in the API or if we should provide it only as a utility from {{flink-contrib}}.
> I would put it in {{flink-contrib}}.
> See my answer on SO: http://stackoverflow.com/questions/30596556/zipwithindex-on-apache-flink
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)