Re: VertexUpdateFunction

Hi Ali :) You could compute the degrees beforehand (e.g. using the Graph.[in|out|get]degrees()) methods and use the resulting dataset as a new vertex dataset. You can now run your vertex-centric computation and access the degrees as vertex value. Cheers, Martin On 29.05.2017 09:28,

Re: Support/connector for Neo4j?

Please let me know, if you need help with the connector or if you want to extend it. Cheers, Martin On 24.03.2017 16:07, alex.decastro wrote: Thanks Tim! I missed that one on Jira. :-) -- View this message in context:

Re: Context-specific step function in Iteration

also work with cross instead of broadcasting, I did not test which way works faster, yet. Apologies if anyone thought about this when it was my error in the end :) Cheers, Martin On 29.05.2016 14:05, Martin Junghanns wrote: Hi everyone, In a step-function (bulk) I'd like to join the wor

Context-specific step function in Iteration

Hi everyone, In a step-function (bulk) I'd like to join the working set W with another data set T. The join field of T depends on the current super step. Unfortunately, W has no access to the iteration runtime context. I tried to extract the current superstep at the beginning of the step

Re: Memory ran out PageRank

) at java.lang.Thread.run(Thread.java:745) Best, Ovidiu On 14 Mar 2016, at 17:36, Martin Junghanns <m.jungha...@mailbox.org> wrote: Hi I think this is the same issue we had before on the list [1]. Stephan recommended the following workaround: A possible workaround is to use the

Re: Memory ran out PageRank

Hi I think this is the same issue we had before on the list [1]. Stephan recommended the following workaround: A possible workaround is to use the option "setSolutionSetUnmanaged(true)" on the iteration. That will eliminate the fragmentation issue, at least. Unfortunately, you cannot set

Re: Long ids from String

; with an autoincrement long id but maybe there's a simpler solution.. > > Best, > Flavio > > On Tue, Nov 3, 2015 at 9:59 AM, Martin Junghanns <m.jungha...@mailbox.org> > wrote: > >> Hi Flavio, >> >> If you just want to assign a unique Long identifier to ea

Re: Fwd: Problem applying a groupReduce function to a grouped data set

Hi, just an idea: In the source code documentation, it states that projectFirst and projectSecond lose type information, which could explain why your group reduce expects . I found an example [1] that calls .types() to define the returned types, but this method is deprecated. What

LDBC Graph Data into Flink

Hi all, For our benchmarks with Flink, we are using a data generator provided by the LDBC project (Linked Data Benchmark Council) [1][2]. The generator uses MapReduce to create directed, labeled, attributed graphs that mimic properties of real online social networks (e.g, degree distribution,

Re: Containment Join Support

-16 9:39 GMT+02:00 Martin Junghanns martin.jungha...@gmx.net mailto:martin.jungha...@gmx.net: Hi everyone, at first, thanks for building this great framework! We are using Flink and especially Gelly for building a graph analytics stack (gradoop.com http

Containment Join Support

Hi everyone, at first, thanks for building this great framework! We are using Flink and especially Gelly for building a graph analytics stack (gradoop.com). I was wondering if there is a [planned] support for a containment join operator. Consider the following example: DataSetListInt left :=