flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <till.rohrm...@gmail.com>
Subject Re: Collect of user defined classes doesn't work
Date Tue, 14 Apr 2015 13:52:20 GMT
Could you check the definition of the collect method in the DataSet.scala
file? Does it contain parentheses or not?

On Tue, Apr 14, 2015 at 3:48 PM, Felix Neutatz <neutatz@googlemail.com>
wrote:

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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message