scala中的datastream经过flatmap后如何获取数组下标

在 Scala 中，可以使用 `zipWithIndex` 方法获取数据流中每个元素对应的下标。例如，将一个 `DataStream` 对象进行 `flatMap` 操作后，可以使用 `zipWithIndex` 方法获取每个元素对应的下标，示例如下：

import org.apache.flink.streaming.api.scala._

val env = StreamExecutionEnvironment.getExecutionEnvironment
val dataStream: DataStream[String] = env.fromElements("a b c", "d e f", "g h i")

val resultStream: DataStream[(String, Int)] = dataStream.flatMap(_.split(" "))
  .zipWithIndex // 获取每个元素对应的下标

在上述代码中，首先创建了一个 `DataStream` 对象 `dataStream`，它包含了三个字符串元素。然后使用 `flatMap` 方法将每个字符串元素拆分成单词，并使用 `zipWithIndex` 方法获取每个单词对应的下标。最终得到的 `resultStream` 是一个包含 `(String, Int)` 元素的数据流，其中元组的第一个元素是单词，第二个元素是单词在数据流中对应的下标。

需要注意的是，在 `zipWithIndex` 方法中，下标是从0开始计数的。如果需要自定义起始下标，可以在 `zipWithIndex` 方法中传入一个起始下标，例如 `zipWithIndex(1)` 将下标从1开始计数。