[FLINK-3626] zipWithIndex in Python API

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: API / Python

Environment

OS X 10.11.3, 16GB RAM, 500GB SSD, Core i7 2.5GHz.

• Assignee: Unassigned
• Reporter: Shannon Quinn
• Created: 16/Mar/16 19:53
• Updated: 22/Jun/16 10:06
• Resolved: 22/Jun/16 10:06

Description

Implementation of a `zipWithIndex` method for the Python API on Flink. This will affix each record with a sequential integer ID, consistent across the distributed data structure.

Work here: https://github.com/magsol/flink

Issue Links

• links to: GitHub Pull Request #2136