Hi Marc,
PageRank and GSAPageRank were moved to the flink-gelly-examples jar in the
org.apache.flink.graph.examples package. A library algorithm was added that
supports both source and sink vertices. This limitation of the old algorithms
was noted in the class documentation and I understand to
Hi there,
why was the PageRank version (which implements the GraphAlgorithm interface)
removed in 1.3?
How can I use the new PageRank implementation in 1.3.x?
Why PageRank doesn’t use the graph processing models (vertex-centric, sg or
gsa) anymore?
Thanks!
Bests,
marc
Hi all,
I would like to match the maximal consecutive sequences of events of type A
in a stream.
I'm using the following :
Pattern.begin("start").where(event is not A)
.next("middle").where(event is A).oneOrMore().consecutive()
.next("not").where(event is not A)
I This give the output I want.
We also have a requirement of using Drools in Flink. Drools brings a very
mature and usable business rules editor. And to be able to integrate Drools
into Flink would be very useful.
On 23 June 2017 at 22:09, Suneel Marthi wrote:
> Sorry I didn't read the whole thread.
>
> We have a similar rqmt