Skip to content

Instantly share code, notes, and snippets.

@timothyrenner

timothyrenner/pyspark_partition_call.py

Created January 30, 2019 22:13
Show Gist options
  • Save timothyrenner/594a9594a93fe2c0e930f45f36559ec3 to your computer and use it in GitHub Desktop.
Save timothyrenner/594a9594a93fe2c0e930f45f36559ec3 to your computer and use it in GitHub Desktop.
Download ZIP
Pyspark Partition Call
Raw
pyspark_partition_call.py
my_data.rdd.mapPartitions(predict_partition).toDF()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment