snippet.scala

al t0 = System.nanoTime()

//  Do repartitioning
fact_table = fact_table.repartition(200, col("uniformly_distributed_column"))

// Create the Execution Plan
fact_table = fact_table.join(broadcast(dimension_table2),
                         fact_table.col("dimension_2_id") === dimension_table.col("id"))

// Perform an action to run the execution
fact_table.count

val t1 = System.nanoTime()
println("Elapsed time: " + (t1 - t0)/10e8 + "s")