Perlito5 - java - Spark example - wip

fglock · Oct 18, 2019 · 47ef73a · 47ef73a
1 parent c77e434
commit 47ef73a
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/misc/Spark/spark.pl b/misc/Spark/spark.pl
@@ -3,7 +3,7 @@ package JavaRDD { import => "org.apache.spark.api.java.JavaRDD" }
 package JavaSparkContext { import => "org.apache.spark.api.java.JavaSparkContext" }
 package SparkSession { import => "org.apache.spark.sql.SparkSession" }
 package Integer { import => "java.lang.Integer" }
-package List::Integer { import => "java.util.ArrayList<java.lang.Integer>" }
+package List { import => "java.util.ArrayList<PlObject>" }
 
 use strict;
 use warnings;
@@ -22,10 +22,9 @@ package List::Integer { import => "java.util.ArrayList<java.lang.Integer>" }
 
 print "slices: $slices; n: $n\n";
 
-my List::Integer $list = List::Integer->new();
+my List $list = List->new();
 for ( 0 .. $n - 1 ) {
-    my Integer $i = int($_);
-    $list->add($i);
+    $list->add($_);
 }
 
 my $dataSet = $jsc->parallelize($list, $slices);
@@ -35,13 +34,13 @@ package List::Integer { import => "java.util.ArrayList<java.lang.Integer>" }
 
 # TODO
 # $count = $dataSet->map(
-#         sub {
+#         sub ($) {
 #               my $x = rand(2) - 1;
 #               my $y = rand(2) - 1;
 #               return ($x * $x + $y * $y <= 1) ? 1 : 0;
 #         }
 #     )->reduce(
-#         sub { $_[0] + $_[1] }
+#         sub ($$) { $_[0] + $_[1] }
 #     );
 
 print "Pi is roughly ", 4.0 * $count / $n, "\n";