Skip to content

Instantly share code, notes, and snippets.

@crocker

crocker/spark-duplicates.scala

Last active July 2, 2020 12:15
Show Gist options
  • Save crocker/bc924a3f2660d47a606be6d84ff17893 to your computer and use it in GitHub Desktop.
Save crocker/bc924a3f2660d47a606be6d84ff17893 to your computer and use it in GitHub Desktop.
Download ZIP
Find duplicates in a Spark DataFrame
Raw
spark-duplicates.scala
val transactions = spark.read
.option("header", "true")
.option("inferSchema", "true")
.json("s3n://bucket-name/transaction.json")
transactions.groupBy("id", "organization").count.sort($"count".desc).show
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment