[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3888:
-
Component/s: Iterations
> Custom Aggregator with Convergence can't be registered direc
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15543133#comment-15543133
]
Vasia Kalavri commented on FLINK-3888:
--
I had a quick look into this and I don't see any fundamental
[
https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536120#comment-15536120
]
Vasia Kalavri commented on FLINK-1815:
--
The motivation for this issue was to (1) provide an easy way
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2564
What I meant is simply creating an edge with a Tuple2 label containing the
labels of the two edges in the bipartite graph. Makes sense?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535748#comment-15535748
]
Vasia Kalavri commented on FLINK-1815:
--
Hi [~fobeligi],
representing a graph as an adjacency list
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2564
Providing a flattened tuple is certainly better than having the user
implement the reduce, but I think we should provide separate methods for the
default and custom operations. A projection is a very
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81217922
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218538
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java ---
@@ -34,10 +34,10 @@
public Edge(){}
- public
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218403
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218056
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218490
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512880#comment-15512880
]
Vasia Kalavri commented on FLINK-4646:
--
Hi [~StephanEwen], thanks! We've discussed this in the parent
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493427#comment-15493427
]
Vasia Kalavri commented on FLINK-2254:
--
It sounds good to me [~ivan.mushketyk]. Please go ahead
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15482143#comment-15482143
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ivan.mushketyk]
thanks a lot for creating the design
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15481915#comment-15481915
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
I see that in order to create the graph you
[
https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445732#comment-15445732
]
Vasia Kalavri commented on FLINK-4522:
--
Hi Greg,
what is the current redirect? The gelly link
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444180#comment-15444180
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ivan.mushketyk],
what you are describing in "w
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15443318#comment-15443318
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
thanks for the update. Regarding
Vasia Kalavri created FLINK-4522:
Summary: Gelly link broken in homepage
Key: FLINK-4522
URL: https://issues.apache.org/jira/browse/FLINK-4522
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439178#comment-15439178
]
Vasia Kalavri commented on FLINK-4440:
--
Alright, makes sense. Let's close this then. Is that fine
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437307#comment-15437307
]
Vasia Kalavri commented on FLINK-4440:
--
I don't have a strong opinion against adding the {{create
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2398
Hi @mushketyk,
thank you for this PR. Is there a corresponding JIRA for it? If not, can
you please create one and tag the PR with it?
Also, make sure you read the [How to contribute
guide
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2254:
-
Comment: was deleted
(was: Hi [~ivan.mushketyk],
thank you for your interest. As far as I know
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428076#comment-15428076
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ivan.mushketyk],
thank you for your interest. As far
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428075#comment-15428075
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ivan.mushketyk],
thank you for your interest. As far
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15421162#comment-15421162
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
I haven't had time to look at your example
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2258
Hi @greghogan, sorry I somehow missed this PR ð
I really like the restructuring, thanks! I don't think it's a problem to
rename to `gelly/index.html`. Just make sure to also update the link
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15412194#comment-15412194
]
Vasia Kalavri commented on FLINK-1707:
--
Thank you for the example [~joseprupi]. I'll try to get back
[
https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15376834#comment-15376834
]
Vasia Kalavri commented on FLINK-4204:
--
Separating drivers and examples sounds like a good idea. Do
[
https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15373767#comment-15373767
]
Vasia Kalavri commented on FLINK-4204:
--
[~greghogan] let me know what you think!
> Clean up ge
Vasia Kalavri created FLINK-4204:
Summary: Clean up gelly-examples
Key: FLINK-4204
URL: https://issues.apache.org/jira/browse/FLINK-4204
Project: Flink
Issue Type: Improvement
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2197
Thanks for the ping @twalthr! I don't see anything suspicious :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2032
I've had an offline discussion with @greghogan about this. We won't be
advertising `DelegatingGraphAlgorithm` as a user-facing feature. +1 from me!
---
If your project is set up for it, you can reply
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2188
Looks good, thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2184
Thanks for the update @greghogan! +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-2352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-2352.
Resolution: Won't Fix
I agree with Greg. Gephi doesn't seem like a good fit.
> [Gr
[
https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15357419#comment-15357419
]
Vasia Kalavri commented on FLINK-1759:
--
I think it would be very helpful. A couple of users have
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2184
Thanks a lot @greghogan. Everything looks good. Can you please update the
docs too?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355673#comment-15355673
]
Vasia Kalavri commented on FLINK-1707:
--
Thanks [~joseprupi]. If you could document the example
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355664#comment-15355664
]
Vasia Kalavri commented on FLINK-3879:
--
You and I are the only Gelly component "shep
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/1967
Hey @greghogan,
was there consensus regarding this change? I see the numbers, but did
anyone review this PR?
I've been offline for the past few days, and I now see that nobody reviewed
#2160
[
https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346395#comment-15346395
]
Vasia Kalavri commented on FLINK-3965:
--
The functionality is much needed in my opinion. My concern
[
https://issues.apache.org/jira/browse/FLINK-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346204#comment-15346204
]
Vasia Kalavri commented on FLINK-4101:
--
Hi [~mrakki3110], JIRA is used for reporting bugs
[
https://issues.apache.org/jira/browse/FLINK-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-4101.
Resolution: Invalid
> Calculating average in Flink DataStream on window t
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346160#comment-15346160
]
Vasia Kalavri edited comment on FLINK-1514 at 6/23/16 9:27 AM:
---
Hi [~michael
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346160#comment-15346160
]
Vasia Kalavri commented on FLINK-1514:
--
Hi [~michael], tis GSA implementation is a variation
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2053
Hi @joseprupi,
thanks a lot for this PR.
I have looked through the code and I'm quite worried about its performance
and scalability. Have you tried it out with any big inputs? We
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873916
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873432
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873061
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67871432
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67869049
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868962
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868917
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868911
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2053
I'll shepherd this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
[
https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338596#comment-15338596
]
Vasia Kalavri commented on FLINK-1815:
--
Hi [~fobeligi], are you by any chance still working
[
https://issues.apache.org/jira/browse/FLINK-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338595#comment-15338595
]
Vasia Kalavri commented on FLINK-3618:
--
[~greghogan] are you working on this? It would be nice
[
https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338593#comment-15338593
]
Vasia Kalavri commented on FLINK-3965:
--
Hey [~greghogan], do we want this in for 1.1.0?
> Delegat
[
https://issues.apache.org/jira/browse/FLINK-2352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2352:
-
Assignee: (was: Shivani Ghatge)
> [Graph Visualization] Integrate Gelly with Ge
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338592#comment-15338592
]
Vasia Kalavri commented on FLINK-3879:
--
Hey [~greghogan], since FLINK-2044 was updated to provide
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-2941.
Resolution: Won't Fix
The connector has been implemented by [~mju] in
https://github.com/s1ck
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15338588#comment-15338588
]
Vasia Kalavri commented on FLINK-2941:
--
Hi,
is there any news regarding this? [~mju], are you going
[
https://issues.apache.org/jira/browse/FLINK-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15332354#comment-15332354
]
Vasia Kalavri commented on FLINK-3916:
--
FLINK-3615 is about extending or refactoring
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2032
Hi,
I don't completely get the reasoning either, but it sounds interesting
indeed!
@greghogan, could you maybe clarify the following for me:
- What do you mean by "mergeable" con
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2036
Thanks @greghogan! It looks like you have some checkstyle violation,
otherwise +1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2053#issuecomment-222640838
Hi @joseprupi,
thanks for the PR! Just a heads-up. There is currently a very high number
of unreviewed PRs and it might take a while until someone finds the time
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306054#comment-15306054
]
Vasia Kalavri commented on FLINK-1707:
--
Thank you [~joseprupi]! When you are ready, open a PR and let
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306053#comment-15306053
]
Vasia Kalavri commented on FLINK-1536:
--
Hi [~rohit13k],
a graph in gelly is represented by 2 datasets
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2036#issuecomment-221811872
Thanks for the PR @greghogan! I left one comment.
The HITS implementation also makes use of the number of vertices in the
same way PageRank did. We can update
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2036#discussion_r64709459
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
---
@@ -327,6 +343,11 @@ private SumUdf
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2036#discussion_r64709426
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
---
@@ -289,6 +300,11 @@ private GatherUdf
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2044.
--
Resolution: Implemented
Fix Version/s: 1.1.0
> Implementation of Gelly HITS Algori
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221637781
Thanks @gallenvara! All tests pass now. I will merge :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2021#discussion_r64589442
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
---
@@ -0,0 +1,81
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221603967
The failures were in the `HITSAlgorithmITCase`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221600182
Hey @gallenvara,
I was about to merge this, but I see test failures after rebasing on top of
master.
Can you please (1) rebase on top of the latest master
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2021#discussion_r64577865
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
---
@@ -0,0 +1,81
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221504600
Thank you @gallenvara. I'll merge later today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221394386
Hey @gallenvara,
I had a private chat with @greghogan about this PR. We think that we should
change the label type to a boolean instead of string. It should make
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2018#issuecomment-221185294
Also looks good! +1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2023#issuecomment-221184374
+1 looks good!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-220628229
Thank you for the update @gallenvara and for your patience with our
continuous comments :)
How many edges did the graphs in your experiment have?
---
If your project
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r64054001
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -273,4 +289,23 @@ public void sendMessages(Vertex
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r64051693
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -243,18 +255,22 @@ public void sendMessages
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r64049343
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2055,22 +2055,22 @@ vertex and edge in the output graph stores the
common group value and the number
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1980#issuecomment-220620841
Thanks for the update @greghogan. I left a few comments for improvements of
the docs. After these are addressed it should be good to merge.
---
If your project is set up
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r64048955
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -43,11 +43,13 @@
import
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r64048499
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/JaccardIndex.java
---
@@ -54,73 +57,112 @@
public
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r64048412
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/JaccardIndex.java
---
@@ -40,9 +43,9 @@
/**
* Driver
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r64048334
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2250,14 +2250,33 @@ graph.run(new TranslateVertexValues(new
LongValueAddOffset(vertexCount
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63899403
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java
---
@@ -0,0 +1,136
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63896459
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/library/similarity/JaccardIndexTest.java
---
@@ -0,0 +1,136
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63895157
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63894471
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63894348
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63894239
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63894069
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java
---
@@ -0,0 +1,462 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63893564
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2051,6 +2052,26 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
vertex
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1980#discussion_r63893177
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/TranslateEdgeDegreeToIntValue.java
---
@@ -0,0 +1,51
101 - 200 of 1146 matches
Mail list logo
