I use the latest maven snapshot:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-scala</artifactId>
<version>0.9-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>0.9-SNAPSHOT</version>
</dependency>
2015-04-14 15:45 GMT+02:00 Robert Metzger <rmetz...@apache.org>:
> 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
> >
>
