[MAHOUT-1789] Remove DataSetOps.scala from mahout-flink, replace by DataSetUtils from Flink 0.10

• Type: Task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0
• Fix Version/s: 0.12.0
• Component/s: classic
• Epic Link: Samsara-framework
• Sprint: Nov/Dec-2015
• Assignee: Suneel Marthi
• Reporter: Suneel Marthi
• Created: 08/Nov/15 04:09
• Updated: 31/Jan/24 22:16
• Resolved: 11/Jan/16 00:11

Description

DataSetOps#zipWithIndex is not needed anymore in light of DataSetUtils available in Flink 0.10+.

DataSetUtils.

{java, scala}

from Flink 0.10+ provides methods - zipWithIndex(), zipWithUniqueId(), sample(), sampleWithSize(); all of which are needed to support Mahout-Flink backend.