[jira] [Resolved] (FLINK-2784) Remove deprecated config keys

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2784. -- Resolution: Done > Remove deprecated config k

[jira] [Resolved] (FLINK-2833) Unstage Gelly and Module refactoring

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2833. -- Resolution: Done > Unstage Gelly and Module refactor

[jira] [Resolved] (FLINK-2782) Remove deprecated features for 0.10

2015-10-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2782. -- Resolution: Done > Remove deprecated features for 0

[GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to...

2015-10-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1241#issuecomment-146902805 :dancers: :tada: :fireworks: merging ^^ --- 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

[jira] [Created] (FLINK-2833) Unstage Gelly and Module refactoring

2015-10-08 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2833: Summary: Unstage Gelly and Module refactoring Key: FLINK-2833 URL: https://issues.apache.org/jira/browse/FLINK-2833 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to...

2015-10-08 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1241 [FLINK-2833] [gelly] unstage Gelly and move to flink-libraries You can merge this pull request into a Git repository by running: $ git pull https://github.com/vasia/flink gelly-restructure

[jira] [Resolved] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2561. -- Resolution: Fixed > Sync Gelly Java and Scala A

[jira] [Resolved] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2785. -- Resolution: Done Fix Version/s: 0.10 > Implement Graph's fromCsvReader in Gelly-Sc

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1205#issuecomment-146225895 Great, thanks! I will re-order the parameters and merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Updated] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2831: - Summary: Failing Test: WrapperSetupHelperTest (was: Failinf Test: WrapperSetupHelperTest

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1211#issuecomment-146237334 The formatting in the rest of the gelly-scala code looks OK. This one got messed up as I copies some methods from the Java examples. I'll fix the formatting and merge

[jira] [Created] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

2015-10-07 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2832: Summary: Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement Key: FLINK-2832 URL: https://issues.apache.org/jira/browse/FLINK-2832 Project: Flink

[jira] [Created] (FLINK-2831) Failinf Test: WrapperSetupHelperTest

2015-10-07 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2831: Summary: Failinf Test: WrapperSetupHelperTest Key: FLINK-2831 URL: https://issues.apache.org/jira/browse/FLINK-2831 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1205#issuecomment-145979805 Hey @chiwanpark, this is how the Java method works, i.e. creates a `CsvReader ` object and returns the graph when calling the appropriate types methods. I only kept

[GitHub] flink pull request: [FLINK-2786] Remove Spargel from source code a...

2015-10-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1229#issuecomment-145800082 Thanks, 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 not have

[jira] [Updated] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-10-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2786: - Fix Version/s: 0.10 > Remove Spargel from source code and update documentation in favor of Ge

[jira] [Resolved] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-10-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2786. -- Resolution: Done > Remove Spargel from source code and update documentation in favor of Ge

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1205#issuecomment-145939652 Thanks so much for the review @fhueske! I agree with your comments. I will rename the parameter to `readVertices`, make it mandatory, and better explain it on the docs

[GitHub] flink pull request: [FLINK-2786] Remove Spargel from source code a...

2015-10-05 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1229 [FLINK-2786] Remove Spargel from source code and update docs. I also ported 2 Spargel tests that we hadn't copied over to Gelly. You can merge this pull request into a Git repository by running

[jira] [Assigned] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-10-05 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2786: Assignee: Vasia Kalavri > Remove Spargel from source code and update documentat

[jira] [Updated] (FLINK-1536) Graph partitioning operators for Gelly

2015-10-04 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1536: - Component/s: (was: Java API) > Graph partitioning operators for Ge

[jira] [Updated] (FLINK-1536) Graph partitioning operators for Gelly

2015-10-04 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1536: - Summary: Graph partitioning operators for Gelly (was: GSoC project: Graph partitioning operators

[jira] [Updated] (FLINK-1536) Graph partitioning operators for Gelly

2015-10-04 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1536: - Labels: (was: graph gsoc2015 java) > Graph partitioning operators for Ge

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-02 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1211 [FLINK-2561] Adds gelly-scala examples This PR addresses the remaining issues of FLINK-2561. It adds 3 gelly-scala examples: one vertex-centric sssp, one gsa-sssp and one showing how to use

[jira] [Reopened] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-10-01 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reopened FLINK-2561: -- This is not completed yet. Lat PR *hopefully* coming today :) > Sync Gelly Java and Scala A

[jira] [Assigned] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-10-01 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2785: Assignee: Vasia Kalavri > Implement Graph's fromCsvReader in Gelly-Sc

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-01 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1205 [FLINK-2785] [gelly] implements fromCsvReader for gelly-scala This is the last method missing from the Scala Graph implementation. In order to be as close as possible to the Java implementation, I

[GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t...

2015-10-01 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1152#issuecomment-144822644 I'm merging this one --- 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

[jira] [Resolved] (FLINK-2663) Update Gelly library methods to use any key type

2015-10-01 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2663. -- Resolution: Done Fix Version/s: 0.10 > Update Gelly library methods to use any key t

[GitHub] flink pull request: [FLINK-2561] [gelly] adds documentation for ge...

2015-09-30 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1204 [FLINK-2561] [gelly] adds documentation for gelly-scala You can merge this pull request into a Git repository by running: $ git pull https://github.com/vasia/flink gelly-scala-docs

[GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t...

2015-09-29 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1152#issuecomment-144117546 Travis has a failure on `YARNSessionFIFOITCase ` (FLINK-2392). If no objections, I can merge this one. --- If your project is set up for it, you can reply

[jira] [Created] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-09-29 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2785: Summary: Implement Graph's fromCsvReader in Gelly-Scala Key: FLINK-2785 URL: https://issues.apache.org/jira/browse/FLINK-2785 Project: Flink Issue Type

[jira] [Updated] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-09-29 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2785: - Issue Type: Sub-task (was: Task) Parent: FLINK-2561 > Implement Graph's fromCsvRea

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1183#discussion_r40544282 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala --- @@ -0,0 +1,31

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1183#issuecomment-143725226 Thank you for the review @StephanEwen! I'll address your comments and merge later. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-2561] Adda missing Gelly scala methods ...

2015-09-25 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1183 [FLINK-2561] Adda missing Gelly scala methods and tests This PR *partially* address FLINK-2561. - It adds all missing methods to Graph, except the recently added (#1149) `fromCsvReader

[jira] [Resolved] (FLINK-1520) Read edges and vertices from CSV files

2015-09-24 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-1520. -- Resolution: Implemented Thanks for your contribution [~shivani94]! > Read edges and verti

[jira] [Updated] (FLINK-1520) Read edges and vertices from CSV files

2015-09-24 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1520: - Fix Version/s: 0.10 > Read edges and vertices from CSV fi

[jira] [Assigned] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-09-24 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2561: Assignee: Vasia Kalavri > Sync Gelly Java and Scala A

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-23 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1105#issuecomment-142635727 Hi @andralungu, if you're not planning to continue on this PR, then I believe you should close it. However, you might want to keep your local branch, in case

[GitHub] flink pull request: [FLINK-1520] [gelly] Create a Graph from CSV f...

2015-09-21 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1149#discussion_r39948730 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java --- @@ -110,24 +105,20 @@ public static void main(String

[GitHub] flink pull request: [FLINK-1520] [gelly] Create a Graph from CSV f...

2015-09-21 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1149#discussion_r39948692 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,486 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520] [gelly] Create a Graph from CSV f...

2015-09-21 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1149#issuecomment-141905875 Thanks @andralungu! I'll address your comments and merge later. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-20 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1105#discussion_r39928365 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleCount.java --- @@ -0,0 +1,208 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-20 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1105#discussion_r39928356 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleCount.java --- @@ -0,0 +1,208 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-20 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1105#discussion_r39928354 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/TriangleCount.java --- @@ -0,0 +1,208 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-20 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1105#issuecomment-141769161 Hey @andralungu, I left some minor comments. Apart from those, I think we should also address the previous comments on (a) returning an `Integer` instead

[jira] [Assigned] (FLINK-2663) Update Gelly library methods to use any key type

2015-09-20 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2663: Assignee: Vasia Kalavri > Update Gelly library methods to use any key t

[GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t...

2015-09-20 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1152 [FLINK-2663] [gelly] Changes library methods to use generic keys This PR updates the Gelly library methods to use generic vertex keys and values where possible. It also adds missing Javadocs

[jira] [Assigned] (FLINK-1520) Read edges and vertices from CSV files

2015-09-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-1520: Assignee: Vasia Kalavri (was: Shivani Ghatge) > Read edges and vertices from CSV fi

[GitHub] flink pull request: [FLINK-1520] [gelly] Create a Graph from CSV f...

2015-09-19 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1149 [FLINK-1520] [gelly] Create a Graph from CSV files This builds on @shghatge's work in #847. I addressed the remaining issues, rebased, and edited the docs. @andralungu, you've already reviewed

[GitHub] flink pull request: Hits

2015-09-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-140669850 Hey @mfahimazizi, thank you for your reply! Could you give me some details on what you mean by "calculate edges values"? What is the computation that you

[GitHub] flink pull request: Hits

2015-09-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-140903149 Thanks for the explanation @mfahimazizi. So, if you put the edge label inside the message that you send in the messaging function, then you will know which values

[GitHub] flink pull request: Hits

2015-09-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-140314739 Hi @mfahimazizi, as I said, it is not possible to access the edge values inside the `VertexUpdateFunction`. However, you can get the same functionality if you

[GitHub] flink pull request: [FLINK-2661] Added Node Splitting Methods

2015-09-14 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1124#issuecomment-140146467 Sure, I'm not saying you shouldn't have opened this PR. I'm trying to save you some time. So, my opinion is that in order for this to be useful, we need 2 things

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-14 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1105#issuecomment-140140403 Sounds good to me! A benchmark would be great, since I can also only guess about the performance ;) --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr...

2015-09-13 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1105#issuecomment-139958798 Hi, I agree with @fhueske that we should consider porting the existing DataSet example to the Gelly library. The algorithm is a bit different and it's not very

[GitHub] flink pull request: [FLINK-2661] Added Node Splitting Methods

2015-09-13 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1124#issuecomment-139959564 Hi @andralungu, I was under the impression that we never really reached consensus in the mailing list thread regarding this addition. I definitely think

[jira] [Created] (FLINK-2663) Update Gelly library methods to use any key type

2015-09-13 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2663: Summary: Update Gelly library methods to use any key type Key: FLINK-2663 URL: https://issues.apache.org/jira/browse/FLINK-2663 Project: Flink Issue Type

[GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li...

2015-08-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1054#issuecomment-134847237 I think you should wait a bit. There is an open discussion in the mailing list on whether to fork 0.9.1 out of the current master. If there is consensus and you merge

[GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li...

2015-08-25 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1054#discussion_r37867925 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java --- @@ -0,0 +1,56 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li...

2015-08-25 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1054#issuecomment-134604410 Thanks for adding this one @andralungu. We really need this algorithm in the library! I have a few comments: - we should clarify what is the expected input graph

[GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li...

2015-08-25 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1054#discussion_r37869349 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java --- @@ -0,0 +1,187 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li...

2015-08-25 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1054#discussion_r37869769 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java --- @@ -0,0 +1,187 @@ +/* + * Licensed

[jira] [Assigned] (FLINK-2563) Gelly's Graph Algorithm Interface is limited

2015-08-23 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-2563: Assignee: Vasia Kalavri Gelly's Graph Algorithm Interface is limited

[GitHub] flink pull request: [FLINK-2563] [gelly] changed Graph's run() to ...

2015-08-23 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1042 [FLINK-2563] [gelly] changed Graph's run() to return an arbitrary result type Added a type parameter to the 'GraphAlgorithm' interface to allow implementing library methods that return single values

[jira] [Commented] (FLINK-2563) Gelly's Graph Algorithm Interface is limited

2015-08-23 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708342#comment-14708342 ] Vasia Kalavri commented on FLINK-2563: -- That's a big limitation, I agree. Mind if I

[jira] [Commented] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

2015-08-22 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707946#comment-14707946 ] Vasia Kalavri commented on FLINK-2548: -- [~ggevay], an approach similar to what you

[jira] [Closed] (FLINK-2451) Cleanup Gelly examples

2015-08-22 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri closed FLINK-2451. Resolution: Fixed Fix Version/s: 0.10 Cleanup Gelly examples

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-08-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-133727559 Thanks for the comments @andralungu! @shghatge, can you please close this PR? I will make the docs update and open a new one, which will include your work and my

[GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa...

2015-08-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/892#issuecomment-133728081 Any progress on this and #923 @shghatge? --- 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

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

2015-08-22 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708099#comment-14708099 ] Vasia Kalavri commented on FLINK-2033: -- I can close this one now, right [~vanaepi

[jira] [Created] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-08-22 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2561: Summary: Sync Gelly Java and Scala APIs Key: FLINK-2561 URL: https://issues.apache.org/jira/browse/FLINK-2561 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API v2

2015-08-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-133730158 I have created [FLINK-2561](https://issues.apache.org/jira/browse/FLINK-2561) for the sync. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

2015-08-22 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1000#issuecomment-133725849 Thank you for the review @andralungu. I will rebase and merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set

2015-08-15 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698399#comment-14698399 ] Vasia Kalavri commented on FLINK-2527: -- I think (3) would break the model semantics

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API v2

2015-08-14 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-131169939 +1 from me too. Thanks for your great work @PieterJanVanAeken! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: [Flink-Gelly] [example] added missing assumpti...

2015-08-13 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/883#issuecomment-130623223 I've actually included this in #1000. Could you close this PR @samk3211? Thanks! --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

2015-08-13 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1000#discussion_r36963490 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java --- @@ -86,26 +72,35 @@ public void

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1000#issuecomment-129175273 ha! I hadn't noticed! That's nice :)) --- 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] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/420#issuecomment-129222936 @balidani, I think it'd be better if you close this PR. I don't think we'll add another example after #1000 is merged. I can take over and probably reuse some of your

[jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method

2015-08-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1707: - Assignee: (was: joey) Add an Affinity Propagation Library Method

[GitHub] flink pull request: [FLINK-1707][WIP]Add an Affinity Propagation L...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/649#issuecomment-129223427 Hi @joey001, any news regarding this PR? If you have no time to work on this, that's fine! You can close the PR and someone will hopefully pick up the issue. Just

[jira] [Updated] (FLINK-1528) Add local clustering coefficient library method and example

2015-08-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-1528: - Description: Add a gelly library method to compute the local clustering coefficient. (was: Add

[jira] [Assigned] (FLINK-1528) Add local clustering coefficient library method and example

2015-08-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-1528: Assignee: Vasia Kalavri (was: Daniel Bali) Add local clustering coefficient library

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-129223234 Hi @markus-h, I'm so sorry it took me so long to look into this.. I agree with Stephan's comment and also it would be great if we could add this option to gather

[GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/420#issuecomment-129226158 Thats' fine :) Thanks for the fast response! --- 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] flink pull request: [FLINK-1707][WIP]Add an Affinity Propagation L...

2015-08-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/649#issuecomment-129226226 Thanks for the fast response and your kind words :) Glad to have collaborated with you, too! --- If your project is set up for it, you can reply to this email and have

[jira] [Updated] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

2015-08-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2452: - Fix Version/s: 0.10 Add a playcount threshold to the MusicProfiles example

[jira] [Resolved] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

2015-08-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2452. -- Resolution: Fixed Add a playcount threshold to the MusicProfiles example

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

2015-08-07 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1000 [FLINK-2451] [gelly] examples and library cleanup This PR contains a refactoring and cleanup of the gelly exmaples and library methods, as discussed in the mailing list. Tests have been adjusted

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

2015-08-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-128681998 I think it's a good idea and it will probably save you time :) Thank you! --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

2015-08-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128445757 Hi, this looks great indeed! Just out of curiosity, why did you write your own bloom filter implementation and not use a ready one, e.g. from guava? I'm

[GitHub] flink pull request: [FLINK-2452] [Gelly] adds a playcount threshol...

2015-08-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/968#issuecomment-128413716 Thanks @fhueske! Any comment @andralungu? Otherwise, I'll merge this :) --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

2015-08-06 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-128420592 Hi @PieterJanVanAeken! Thanks for the update. It seems something went wrong with your merge. Your last commit shows 1000+ files changed... Could you try to rebase instead

[jira] [Created] (FLINK-2451) Cleanup Gelly examples

2015-07-31 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2451: Summary: Cleanup Gelly examples Key: FLINK-2451 URL: https://issues.apache.org/jira/browse/FLINK-2451 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

2015-07-31 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2452: - Summary: Add a playcount threshold to the MusicProfiles example (was: Add a playcount threshold

[GitHub] flink pull request: [FLINK-2452] [Gelly] adds a playcount threshol...

2015-07-31 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/968 [FLINK-2452] [Gelly] adds a playcount threshold to the MusicProfiles example This PR adds a user-defined parameter to the MusicProfiles example that filters out songs that a user has listened to only

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

2015-07-28 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2411: - Assignee: Martin Junghanns Add basic graph summarization algorithm

[jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm

2015-07-28 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14643995#comment-14643995 ] Vasia Kalavri commented on FLINK-2411: -- Hi [~mju]! Thank you for the detailed

<    3   4   5   6   7   8   9   10   11   12   >