pagerank.clj

;; pagerank in podwerkeg
(reduce (fn [ranks _]
          (keg/rdd (keg/join links ranks)
            (x/for [[page-id [page-links rank]] %
                    dest page-links]
              [dest (/ rank (count page-links))])
            (keg/by-key (x/reduce +) (map #(+ 0.15 (* 0.85 %))))))
  (keg/rdd links (keg/by-key (map (constantly 1)))) (range 10))

pagerank.scala

// pagerank in scala
var ranks = links.mapValues(v => 1.0)

for (i <- 0 until 10) {
  val contributions = links.join(ranks).flatMap {
    case (pageId, (pageLinks, rank)) =>
      pageLinks.map(dest => (dest, rank / pageLinks.size))
  }
  ranks = contributions.reduceByKey((x, y) => x + y).mapValues(v => 0.15 + 0.85*v)
}