@Till: Yes, it works without the parentheses :) Thanks :)
2015-04-14 16:52 GMT+02:00 Felix Neutatz <neut...@googlemail.com>:
> I don't know. I can only see the following:
>
> def collect : scala.collection.mutable.Buffer[T] = { /* compiled code */ }
>
> When do they update the latest snapshot on Maven?
>
>
> 2015-04-14 15:52 GMT+02:00 Till Rohrmann <till.rohrm...@gmail.com>:
>
>> 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 <neut...@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 <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
>> > > >
>> > >
>> >
>>
>
>
