[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041645#comment-15041645
]
Vasia Kalavri commented on FLINK-3118:
--
+1
It seems that the same improvement can be also applied
[
https://issues.apache.org/jira/browse/FLINK-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15038034#comment-15038034
]
Vasia Kalavri commented on FLINK-3108:
--
Hey [~twalthr],
I simply copy-pasted your response here
Vasia Kalavri created FLINK-3108:
Summary: JoinOperator's with() calls the wrong TypeExtractor method
Key: FLINK-3108
URL: https://issues.apache.org/jira/browse/FLINK-3108
Project: Flink
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1425#issuecomment-161003995
Hi @aljoscha,
thanks for fixing this! It seems that, with this change, when you union a
stream with itself you get each element twice. If this is intentional, could
Vasia Kalavri created FLINK-3080:
Summary: Cannot union a data stream with a product of itself
Key: FLINK-3080
URL: https://issues.apache.org/jira/browse/FLINK-3080
Project: Flink
Issue Type
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1402#issuecomment-159566437
I still think there's no reason for `Left` and `Right` to be public
classes, especially if you keep the static creation methods. But, if this is
just me, go ahead
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1371#issuecomment-158003742
Thanks! Updated. I'll open a JIRA for integrating it into the TypeExtractor.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Vasia Kalavri created FLINK-3046:
Summary: Integrate the Either Java type with the TypeExtractor
Key: FLINK-3046
URL: https://issues.apache.org/jira/browse/FLINK-3046
Project: Flink
Issue
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1371#issuecomment-158042526
Thanks. I'll squash the commits and 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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1371#issuecomment-158051108
Hey @twalthr, thanks!
I've created FLINK-3046 for the Either integration and I think FLINK-3042
is about custom type interfaces.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3002.
--
Resolution: Implemented
> Add an EitherType to the Java
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013577#comment-15013577
]
Vasia Kalavri commented on FLINK-3049:
--
I see. I was actually confused to see types both in {{flink
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1371#issuecomment-157767153
Thanks a lot for the review. I've updated the PR.
@gyfora @StephanEwen what do you mean by adding this to the type extractor?
What do I need to do?
Also, any
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1371#discussion_r45250671
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/EitherSerializer.java
---
@@ -0,0 +1,194 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1371#discussion_r45250469
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/Either.java ---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the Apache Software
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1370#issuecomment-157659857
Awesome, thanks Till!
---
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-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008883#comment-15008883
]
Vasia Kalavri commented on FLINK-3002:
--
Alright, specifically creating a {{Left}} means I can reuse
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008784#comment-15008784
]
Vasia Kalavri commented on FLINK-3002:
--
No, in fact, I didn't go with the abstract version :-)
I do
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008853#comment-15008853
]
Vasia Kalavri commented on FLINK-3002:
--
I agree [~StephanEwen], that was my reasoning as well. What
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1356#issuecomment-157385739
Thanks a lot for the PR @smarthi! +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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1370#issuecomment-157500925
Thanks a lot for fixing this @tillrohrmann!
I actually like the new behavior better ;) Could you please also update the
gelly guide?
One more thing, some
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1371
[FLINK-3002] Add Either type to the Java API
Implemented as discussed in the corresponding JIRA.
I haven't added this type to the docs yet. The data types section in the
programming guide
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2044:
-
Issue Type: New Feature (was: Improvement)
> Implementation of Gelly HITS Algori
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15005360#comment-15005360
]
Vasia Kalavri commented on FLINK-3002:
--
Here's my first take on this:
https://github.com/vasia/flink
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15003844#comment-15003844
]
Vasia Kalavri commented on FLINK-3002:
--
I took a look at Scala's Either and at existing types
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15003866#comment-15003866
]
Vasia Kalavri commented on FLINK-3002:
--
Thanks Fabian!
A problem with this is that I cannot define
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15003921#comment-15003921
]
Vasia Kalavri commented on FLINK-3002:
--
Maybe I misunderstood you. What I mean is that I cannot do
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3002:
Assignee: Vasia Kalavri
> Add an EitherType to the Java
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2905.
--
Resolution: Implemented
> Add intersect method to Graph cl
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2905:
-
Fix Version/s: 1.0
> Add intersect method to Graph cl
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1329#issuecomment-155023028
Thanks @s1ck! It looks good :-) 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
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1329#discussion_r44008153
--- Diff:
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -968,6 +968,46 @@ TypeInformation : ClassTag
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1329#discussion_r44008216
--- Diff:
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -968,6 +968,46 @@ TypeInformation : ClassTag
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1333
[doc] fix spelling mistakes in the transformations guide
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink transformations-doc
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1329#discussion_r44008025
--- Diff: docs/libs/gelly_guide.md ---
@@ -485,13 +485,15 @@ val networkWithWeights =
network.joinWithEdgesOnSource(vertexOutDegrees, (v1: Do
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1329#discussion_r44008073
--- Diff: docs/libs/gelly_guide.md ---
@@ -485,13 +485,15 @@ val networkWithWeights =
network.joinWithEdgesOnSource(vertexOutDegrees, (v1: Do
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1329#issuecomment-154055282
Hey @s1ck,
thanks a lot for the PR! I left a few minor comments on the docs.
One thing that confuses me is what is the difference between
'graph1.intersect
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1333#issuecomment-154169421
Thank you @rmetzger. I'll 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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1329#issuecomment-154060039
hmm I see. It's not very nice to have 2 different ways of doing the same
thing imo. Could we just keep the second one maybe?
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989271#comment-14989271
]
Vasia Kalavri commented on FLINK-2905:
--
Sure, please go ahead!
> Add intersect method to Graph cl
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989228#comment-14989228
]
Vasia Kalavri commented on FLINK-2905:
--
Hey Martin,
the problem with the vertex values
[
https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14982293#comment-14982293
]
Vasia Kalavri commented on FLINK-2910:
--
+1
We could actually make a larger effort to combine other
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14982523#comment-14982523
]
Vasia Kalavri commented on FLINK-2926:
--
Hi [~mliesenberg],
what kind of iteration are you planning
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14982284#comment-14982284
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ssaumitra],
the tests for the graph methods
Vasia Kalavri created FLINK-2941:
Summary: Implement a neo4j - Flink/Gelly connector
Key: FLINK-2941
URL: https://issues.apache.org/jira/browse/FLINK-2941
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2941:
-
Description:
By connecting Flink/Gelly with a graph database like neo4j we can facilitate
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980871#comment-14980871
]
Vasia Kalavri commented on FLINK-2905:
--
Hey [~mju],
thanks! I took a quick look at your code and here
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976089#comment-14976089
]
Vasia Kalavri commented on FLINK-2909:
--
Thank you [~greghogan]. Then, could you edit the title
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976558#comment-14976558
]
Vasia Kalavri commented on FLINK-2905:
--
This is still not clear to me.
Correct me if I'm wrong
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976941#comment-14976941
]
Vasia Kalavri commented on FLINK-2905:
--
Yes, exactly, group the edges and apply a UDF to produce
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976488#comment-14976488
]
Vasia Kalavri commented on FLINK-2905:
--
I see what you mean, but I'm a bit confused by Call 1. Since
[
https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973972#comment-14973972
]
Vasia Kalavri commented on FLINK-2905:
--
Hi [~mju],
several {{Graph}} methods use the composite
[
https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2411.
--
Resolution: Implemented
Fix Version/s: 1.0
> Add basic graph summarization algori
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1269#issuecomment-151077098
I'll merge this.
---
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-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973937#comment-14973937
]
Vasia Kalavri commented on FLINK-2909:
--
Hi [~greghogan],
thank you for opening this issue :)
Can you
[
https://issues.apache.org/jira/browse/FLINK-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2887.
--
Resolution: Fixed
Fix Version/s: 0.10
> sendMessageToAllNeighbors igno
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1281#issuecomment-150168427
Sure. Shall I do this after merging to master or shall we wait until we
have more fixes for the RC?
---
If your project is set up for it, you can reply to this email
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1281#discussion_r42726773
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java
---
@@ -129,24 +133,43 @@ public void postSuperstep
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1281#issuecomment-150163452
Thanks for reviewing @fhueske! I will add a comment to clarify what happens
with the edge directions and merge this :)
---
If your project is set up for it, you can
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1281#issuecomment-150172859
Alright, will do. Thanks Fabian!
---
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 pull request:
https://github.com/apache/flink/pull/1269#issuecomment-150205489
Hi @s1ck,
the PR looks good! This will be a great addition to the Gelly library ^^
+1 to merge.
---
If your project is set up for it, you can reply to this email
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1281
[FLINK-2887] [gelly] sendMessageToAllNeighbors respects the EdgeDirection
The method now checks whether the edge direction has been set and collects
the correct msg.
You can merge this pull request
Vasia Kalavri created FLINK-2887:
Summary: sendMessageToAllNeighbors ignores the EdgeDirection
Key: FLINK-2887
URL: https://issues.apache.org/jira/browse/FLINK-2887
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14966699#comment-14966699
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ssaumitra],
you are right. Specialized algorithms
[
https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2033.
--
Resolution: Fixed
Fix Version/s: 0.10
> Add overloaded methods with expli
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964862#comment-14964862
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ssaumitra],
thank you for your interest in working
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-149147761
Hi @shghatge,
are you still working on this and #923?
If not, could you please close these 2 PRs? Thanks a lot!
---
If your project is set up for it, you can reply
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1264#issuecomment-149146618
Hi @s1ck,
thank you for the PR! I will try to review this as soon as possible :)
Could you please also add a description of the algorithm in the gelly
guide? I've
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/765#issuecomment-149148599
Hi @mfahimazizi,
is there any update regarding this PR? If you're not planning to keep
working on it, could you please close this? Thanks a lot!
---
If your project
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1263#issuecomment-149219197
Thank you Fabian :))
---
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/1250#issuecomment-148988753
I will add a description in the docs, squash the commits, and merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2714:
-
Fix Version/s: 0.10
> Port the Flink DataSet Triangle Enumeration example to the Gelly libr
[
https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2855:
-
Fix Version/s: 0.10
> Add a documentation section for Gelly library meth
[
https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2855.
--
Resolution: Fixed
> Add a documentation section for Gelly library meth
[
https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2855:
-
Affects Version/s: 0.10
> Add a documentation section for Gelly library meth
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1250#issuecomment-148663100
Thanks a lot for the quick update @ssaumitra! It looks good now :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-2857:
Assignee: Vasia Kalavri
> Gelly API improveme
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1258#issuecomment-148756149
Thanks a lot for the review @fhueske!
I'll address your comments and merge :)
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1263
[FLINK-2857] [gelly] API improvements
This PR:
- renames the mapper parameter in creation methods to `vertexInitializer`,
so that its purpose is easier to understand.
- add `fromTuple2DataSet
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42106061
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
Vasia Kalavri created FLINK-2857:
Summary: Gelly API improvements
Key: FLINK-2857
URL: https://issues.apache.org/jira/browse/FLINK-2857
Project: Flink
Issue Type: Improvement
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42105854
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java
---
@@ -20,10 +20,12 @@
import
[
https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-2855:
Assignee: Vasia Kalavri
> Add a documentation section for Gelly library meth
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42105949
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1250#issuecomment-148347416
Hi @ssaumitra,
thanks a lot for updating the PR! I have left a few minor comments that
should be easy to fix.
---
If your project is set up for it, you can reply
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42105999
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42105936
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42107077
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2855:
-
Description:
We should add a separate documentation section for the Gelly library methods
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42107165
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
Vasia Kalavri created FLINK-2855:
Summary: Add a documentation section for Gelly library methods
Key: FLINK-2855
URL: https://issues.apache.org/jira/browse/FLINK-2855
Project: Flink
Issue
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1250#discussion_r42113501
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleEnumerator.java
---
@@ -0,0 +1,347 @@
+/*
+ * Licensed
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1258
[FLINK-2855] [gelly] Add documentation for the Gelly library methods
This PR adds detailed documentation about the available Gelly library
methods and improves the javadocs of the library methods
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1250#issuecomment-147180092
Sure, will do! Thank you!
---
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-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2714:
-
Summary: Port the Flink DataSet Triangle Enumeration example to the Gelly
library (was: Port
[
https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14952207#comment-14952207
]
Vasia Kalavri commented on FLINK-2411:
--
Hi [~mju],
it sounds reasonable to me. In most cases, you
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1250#issuecomment-147178962
Hi @ssaumitra! Thanks a lot for the pull request, it looks good.
I was thinking, since this algorithm not only counts but actually
enumerates all triangles, we could
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1250#issuecomment-147179792
Yes @ssaumitra, if we have the enumerator, then it's a matter of calling a
`count` to get the number of triangles. So, let's just got for
`TriangleEnumerator
[
https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14952219#comment-14952219
]
Vasia Kalavri commented on FLINK-2411:
--
Oh I see. But then, as you said, it's only a matter of a map
[
https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2714:
-
Description:
Currently, the Gelly library contains one method for counting the number
601 - 700 of 1146 matches
Mail list logo
