Introduction of new Gelly developper

Hello, everyone, I am ZHOU Yi, a student working in graph algorithm, especially graph combinatorial algorithms. I am glad to join the Flink devlopping group. I am working on Gelly graph library, hopping to devote improvements and new features to Gelly graph library (algorithms library, graph

Introduction of new Gelly developper

Hello, everyone, I am ZHOU Yi, a student working in graph algorithm, especially graph combinatorial algorithms. I am glad to join the Flink devlopping group. I am working on Gelly graph library, hopping to devote improvements and new features to Gelly graph library (algorithms library, graph

Affinity propagation for Gelly

Hello everyone, I am working on affinity propagation implementation for Gelly (FLINK 1707 ).The algorithm passes messages between every pair of vertices (NOT every pair of connected vertices) in each iteration with computation complexity

Gelly message type

I have a question about Gelly, can i use Tuple2 as message type?

[Gelly] question about vertex-centric Iteration

Hello, In vertex-centric Iteration, in each iteration, the vertices sends and recieves messages once. However, to implement Affinity Propogation algortihm, I need to update responsibility and availability in one iteration(superstep): 1, each vertex send and recieves messages from neigbor vertic

Gelly, problem vertex centric iteration

Hello everyone, I need some suggestions about debuging the Affinity Appropogation algorithm for gelly. In my implementation, there is a problem with the MessagingFunction in Vertex Centric Iteration The test graph is a completed directed graph (25 vertices in total), i.e. there are two oppo

Gelly, problem vertex centric iteration

Hello everyone, I need some suggestions about debuging the Affinity Appropogation algorithm for gelly. In my implementation, there is a problem with the MessagingFunction in Vertex Centric Iteration The test graph is a completed directed graph (25 vertices in total), i.e. there are two oppo

Fwd: Error in eclipse

Hello all, I import flink/gelly in Eclipse 4.4.2. But in the test code, the IDE always prompt TestExecutionMode cannot be resolved to a type. I find TestExecutionMode is a enum type in org.apache.flink.test.util. Apart from this, the other parts works well, there is no error in the main code.

Error in eclipse

Hello all, I import flink/gelly in Eclispe 4.4.2. But in the test code, the IDE always prompt TestExecutionMode cannot be resolved to a type. I find TestExecutionMode is a enum type in org.apache.flink.test.util. Apart from this, the other parts works well, there is no error in the main code.

Re: Error in eclipse

k committer who is using Eclipse to develop Flink. Setting up Eclipse for Flink is quite hard because we are a mixed Scala/Java project. Check out this page in the documentation: http://ci.apache.org/projects/flink/flink-docs-master/internals/ide_setup.html On Mon, May 4, 2015 at 12:14 AM,

Generat DataSet gaussian distribution

Hello, all when I tested AP algorithm, I had a little question : how to generate a DataSet in gaussian distribution? Is there a implemented funtion? Does any one has a solution? Thank you, ZHOU Yi

[Question]Test failed in cluster mode

le.com/javase/7/docs/api/java/util/Random.html#nextGaussian%28%29 Not sure if this helps, but there is a paper on generating this kind of distribution. http://ifisc.uib-csic.es/raul/publications/P/P44_tc93.pdf Best of luck, Andra On Fri, May 8, 2015 at 9:45 PM, Yi ZHOU wrote: Hello, all when I

Re: [Question]Test failed in cluster mode

nsitive. The cluster mode uses parallelism 4 by default, the collection execution is single threaded (parallelism 1). You can force the parallelism to be always one by setting it on the execution environment. Stephan On Wed, May 13, 2015 at 12:44 AM, Yi ZHOU wrote: Hello, Thanks Andra