You can always have the vertex value being a tuple3 and let the user set
only a part of it (the value).
It would work the same way as with the vertex key - the user function can
see it, but not change it.
On Sat, Mar 21, 2015 at 8:42 PM, Andra Lungu wrote:
> Hi Stephan,
>
> You got the idea! I
Hi Stephan,
You got the idea! I wanted to make the inDeg and outDeg part of the value
itself(that was one of my first versions), but then I thought it would be
too annoying for a user who does not want to access the degrees in
vertexUpdate/ sendMessages to carry them around.
Because in this scena
Hi Andra!
I am still not 100% sure about the cause of the problem, but here is a bit
of background on how we model the computation as a delta iteration and how
you can extend the vertex state. Maybe that helps answer your question.
When using delta iterations for vertex-centric iterations, we kee
Hi Stephan,
What I am trying to do, among other things, is to make the vertex's
inDegree and outDegree available in the vertexUpdate and sendMessages
functions via vertex.getInDegrees().
That is almost done: https://github.com/andralungu/flink/tree/spargelExt
Only the problem is that the inDegree
Hi Andra!
I am not sure I am getting exactly what the question is. The code you
pasted is from the Spargel API - specifically just forwarding registered
broadcast variables.
What do you mean with "the vertex values get reset" ?
Stephan
PS: The delta iterations are based in this paper:
http://ar
Did you send an empty email to user-subscr...@flink.apache.org ? That
should subscribe you.
On Thu, Mar 19, 2015 at 9:25 AM, Andra Lungu wrote:
> Hello,
>
> I've used delta iterations several times up until now, but I just realized
> that I never fully understood what happens inside. And the doc
Hello,
I've used delta iterations several times up until now, but I just realized
that I never fully understood what happens inside. And the documentation
only explains things from a user's perspective. Which is why I could really
use your help :).
Here goes nothing:
In Gelly, Graph.java, there i
