Fwd: Collect of user defined classes doesn't work

[Felix Neutatz]

Hi,

I want to run the following example:

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

case class EdgeType(src: Int, target: Int)

object Test {
   def main(args: Array[String]) {
      implicit val env = ExecutionEnvironment.getExecutionEnvironment

      val graphEdges = readEdges("edges.csv")

      graphEdges.collect()
   }
   def readEdges(file: String)(implicit env: ExecutionEnvironment) = {
      env.readCsvFile[EdgeType](file, "\n", "\t")
   }
}

But IntelliJ doesn't compile it and gives me the following explanation:


Error:(31, 21) not enough arguments for method apply: (n: Int)EdgeType
in trait BufferLike.
Unspecified value parameter n.
                graphEdges.collect()
                                  ^

Can anyone help me out here?

Thanks,

Felix