konnte nicht impliziten Wert für Beweise Parameter finden

Question

Ich bin ein einfacher Wortzählimpuls flink Job zu schreiben, aber ich halte diesen Fehler:

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}} 

ich das Netz gesucht, aber keine nachvollziehbare Antwort bekommen konnte.

Hier ist mein Code:

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

das Hinzufügen von: implicit val typeInfo = TypeInformation.of(classOf[(String)]) als die erste Zeile in def main(args: Array[String]) {...} es für mich fixiert.

object Job { 
    def main(args: Array[String]) { 
    implicit val typeInfo = TypeInformation.of(classOf[(String)]) //Add this here 
    // 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") 
    } 
}