summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSanto Cariotti <santo@dcariotti.me>2024-12-31 12:28:18 +0100
committerSanto Cariotti <santo@dcariotti.me>2024-12-31 12:28:18 +0100
commit54754e539332d569ce72ee47528cbb43ad24a47d (patch)
tree8e14bb8a403e130b57bb008ba866501cbbc980b6
parent4107698a14f4b711393385fc9a919b97ac5fb79e (diff)
Remove println
-rw-r--r--co-purchase-analysis/src/main/scala/Main.scala9
1 files changed, 0 insertions, 9 deletions
diff --git a/co-purchase-analysis/src/main/scala/Main.scala b/co-purchase-analysis/src/main/scala/Main.scala
index a55be03..a12c850 100644
--- a/co-purchase-analysis/src/main/scala/Main.scala
+++ b/co-purchase-analysis/src/main/scala/Main.scala
@@ -114,15 +114,6 @@ object CoPurchaseAnalysis {
ProductPair(Math.min(p1, p2), Math.max(p1, p2)) -> 1
}
}
- .foreach(println)
- data
- .groupBy(_.orderId)
- .flatMap { case (_, orders) =>
- orders.map(_.productId).toSeq.sorted.combinations(2).map {
- case List(p1, p2) =>
- ProductPair(Math.min(p1, p2), Math.max(p1, p2)) -> 1
- }
- }
.reduceByKey(_ + _)
.map { case (ProductPair(product1, product2), count) =>
s"${product1},${product2},${count}"