diff --git a/warcbase-core/src/main/scala/org/warcbase/spark/matchbox/ExtractPopularImages.scala b/warcbase-core/src/main/scala/org/warcbase/spark/matchbox/ExtractPopularImages.scala
index 7aaeaba..253d24d 100644
--- a/warcbase-core/src/main/scala/org/warcbase/spark/matchbox/ExtractPopularImages.scala
+++ b/warcbase-core/src/main/scala/org/warcbase/spark/matchbox/ExtractPopularImages.scala
@@ -1,26 +1,27 @@
 package org.warcbase.spark.matchbox
 
+import org.apache.spark.SparkContext
 import org.warcbase.spark.rdd.RecordRDD._
 import org.apache.spark.rdd.RDD
 import org.warcbase.spark.archive.io.ArchiveRecord
 
 
 /**
   * Extract most popular images
   *
   * limit: number of most popular images in the output
   * timeoutVal: time allowed to connect to each image
   */
 object ExtractPopularImages {
-  def apply(records: RDD[ArchiveRecord], limit: Int, minWidth: Int = 30, minHeight: Int = 30) = {
+  def apply(records: RDD[ArchiveRecord], limit: Int, sc:SparkContext, minWidth: Int = 30, minHeight: Int = 30) = {
     val res = records
       .keepImages()
       .map(r => ((r.getUrl, r.getImageBytes), 1))
       .map(img => (ComputeMD5(img._1._2), (ComputeImageSize(img._1._2), img._1._1, img._2)))
       .filter(img => img._2._1._1 >= minWidth && img._2._1._2 >= minHeight)
       .reduceByKey((image1, image2) => (image1._1, image1._2, image1._3 + image2._3))
       .takeOrdered(limit)(Ordering[Int].on(x => -x._2._3))
     res.foreach(x => println(x._2._2 + "\t" + x._2._3))
-    res
+    sc.parallelize(res.map(x=>x._2._2 + "\t" +  x._2._3), 1)
   }
 }