Skip to content

Instantly share code, notes, and snippets.

View supremum76's full-sized avatar

Andrey Khomich supremum76

View GitHub Profile
import org.apache.spark
import org.apache.spark.sql.Row
import org.apache.spark.sql.types.{FloatType, StringType, StructField, StructType}
import org.apache.spark.sql.expressions.Window
import org.apache.spark.sql.functions.{lit, percentile_approx, collect_list, desc, concat_ws, row_number}
import org.apache.spark.sql.functions.{broadcast}
object BostonCrimesMapSQL extends App{
//--------------- FILES PATH ----------------------------------------------------------------------------------------
val crimesFilePath = args(0)