scala - 找不到证据参数的隐含值

Question

我正在编写一个简单的字数统计 flink 作业，但我不断收到此错误:

could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[String]
[error]  .flatMap{_.toLowerCase.split("\\W+") filter {_.nonEmpty}}

我在网上搜索，但无法得到任何可理解的答案。

这是我的代码:

object Job {
  def main(args: Array[String]) {
    // set up the execution environment
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val dataStream = env.readTextFile("file:///home/plivo/code/flink/scala/flinkstream/test/")

    val count = dataStream
                .flatMap{_.toLowerCase.split("\\W+") filter {_.nonEmpty}}
                .map{ (_,1) }
                .groupBy(0)
                .sum(1)


    dataStream.print()
    env.execute("Flink Scala API Skeleton")
    }
}

Answer 1

你必须导入

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

启用隐式转换，而不是为您使用的每种类型创建隐式值。