"Cannot resolve map"

[Thomas FOURNIER]

Hello,

In the following code,  map { case (id,(label, count)) => (label,id) } is
not resolved.
Is it related to zipWithIndex (org.apache.flink.api.scala) operation ?

My input is a DataSet[String] and I'd like to output a
DataSet[(String,Long)]


val mapping = input

  .map( (s => (s, 1)) )
  .groupBy( 0 )
  .reduce( (a, b) => (a._1, a._2 + b._2) )
  .partitionByRange( 1 )
  .zipWithIndex
  .map { case (id,(label, count)) => (label,id) }



Thanks
Regards

Thomas