@Till: Yes, it works without the parentheses :) Thanks :)
2015-04-14 16:52 GMT+02:00 Felix Neutatz :
> 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
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 :
> Could you check the definition of the collect method in the DataSet.scala
> file
Hi,
I assume that your graphEdges is of type DataSet[EdgeType], right?
Depending on the version you're using the reason might be that the collect
method in the old version does not expect parameters. Thus your parentheses
actually call the apply method on the returned Scala buffer.
In the latest
I use the latest maven snapshot:
org.apache.flink
flink-scala
0.9-SNAPSHOT
org.apache.flink
flink-clients
0.9-SNAPSHOT
2015-04-14 15:45 GMT+02:00 Robert Metzger :
> Hi,
>
> which version of Flink are you using?
>
> On Tue, Apr 14, 2015 at 3:36 PM, Felix Neutatz
> wrote:
>
> > H
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
wrote:
> I use the latest maven snapshot:
>
>
> org.apache.flink
> flink-scala
> 0.9-SNAPSHOT
>
>
> org.apache.flink
> f
Hi,
which version of Flink are you using?
On Tue, Apr 14, 2015 at 3:36 PM, Felix Neutatz
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]) {
> im
