You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by be...@apache.org on 2021/10/26 12:24:42 UTC

[incubator-wayang] branch main updated: [RELEASE][PREPARATION] remove the datasource take it from wikipedia

This is an automated email from the ASF dual-hosted git repository.

bertty pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git


The following commit(s) were added to refs/heads/main by this push:
     new aaa47e0  [RELEASE][PREPARATION] remove the datasource take it from wikipedia
     new 62d8776  Merge branch 'main' of https://github.com/apache/incubator-wayang
aaa47e0 is described below

commit aaa47e07d762ddc838e5ba52cc7af7727e1b821a
Author: Bertty Contreras-Rojas <be...@scalytics.io>
AuthorDate: Tue Oct 26 14:23:58 2021 +0200

    [RELEASE][PREPARATION] remove the datasource take it from wikipedia
    
    Signed-off-by: bertty <be...@gmail.com>
---
 .../java/org/apache/wayang/tests/WayangPlans.java   | 21 ++++++++++-----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlans.java b/wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlans.java
index a47cb36..6e40003 100644
--- a/wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlans.java
+++ b/wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlans.java
@@ -574,18 +574,17 @@ public class WayangPlans {
      * Creates a cross-community PageRank Wayang plan, that incorporates the {@link PageRankOperator}.
      */
     public static WayangPlan pageRankWithDictionaryCompression(Collection<Tuple2<Character, Float>> pageRankCollector) {
-        // Get some graph data. Use the example from Wikipedia: https://en.wikipedia.org/wiki/PageRank
         Collection<char[]> adjacencies = Arrays.asList(
-                new char[]{'B', 'C'},
-                new char[]{'C', 'B'},
-                new char[]{'D', 'A', 'B'},
-                new char[]{'E', 'B', 'D', 'F'},
-                new char[]{'F', 'B', 'E'},
-                new char[]{'G', 'B', 'E'},
-                new char[]{'H', 'B', 'E'},
-                new char[]{'I', 'B', 'E'},
-                new char[]{'J', 'E'},
-                new char[]{'K', 'E'}
+                new char[]{'B', 'D'},
+                new char[]{'C', 'I'},
+                new char[]{'D', 'F', 'B'},
+                new char[]{'E', 'H', 'D', 'K'},
+                new char[]{'F', 'A', 'B'},
+                new char[]{'G', 'A', 'B'},
+                new char[]{'H', 'A', 'B'},
+                new char[]{'I', 'A', 'B'},
+                new char[]{'J', 'G'},
+                new char[]{'K', 'H'}
         );
 
         // Create a WayangPlan: