Change config

Author: Vallasc

jar/binary.jar

@@ -38,8 +38,7 @@ class SparkJob(val padding: Int = 3,
         val splitted = splitImage(inputMatrix)
 
         // Make RDD of matrixes
-        //val matrixes = sc.parallelize(splitted._1, splitted._2 * splitted._3 * 100)
-        val matrixes = sc.parallelize(splitted._1)
+        val matrixes = sc.parallelize(splitted._1, splitted._2 * splitted._3 * 100)
         matrixes.partitionBy(new HashPartitioner(splitted._2 * splitted._3 * 100)).persist(StorageLevel.MEMORY_ONLY)
         val computed = compute(matrixes, pipeline)
 
@@ -49,8 +48,6 @@ class SparkJob(val padding: Int = 3,
 
         // Remove padding border
         out(0 to inputMatrix.rows -1, 0 to inputMatrix.cols -1).copy
-
-        //edges.partitionBy(new RangePartitioner(SparkContextSingleton.DEFAULT_PARALLELISM, edges)).persist(StorageLevel.MEMORY_AND_DISK)
     }