Hi,
which version of Flink are you using?
On Tue, Apr 14, 2015 at 3:36 PM, Felix Neutatz <neut...@googlemail.com>
wrote:
> 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
>
