如何在Apache Flink中使用Scala执行平均运算

libraryDependencies += "org.apache.flink" %% "flink-scala" % "1.13.2"

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

val env = ExecutionEnvironment.getExecutionEnvironment

val inputPath = "path/to/input/file.txt"
val data = env.readTextFile(inputPath)

val result = data.map(_.toDouble).reduce(_ + _) / data.count()

result.print()

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

val env = ExecutionEnvironment.getExecutionEnvironment

val inputPath = "path/to/input/file.txt"
val data = env.readTextFile(inputPath)

val result = data.map(_.toDouble).reduce(_ + _) / data.count()

result.print()

env.execute("Scala Average Calculation")