Skip to content

Instantly share code, notes, and snippets.

@Arnonrgo
Created August 9, 2015 09:40
Show Gist options
  • Save Arnonrgo/19f1289840ae46780ad7 to your computer and use it in GitHub Desktop.
Save Arnonrgo/19f1289840ae46780ad7 to your computer and use it in GitHub Desktop.
(let [..
schema (trans/extract-dataframe-schema (record-builder nil))
..
rdd (spark/map record-builder some-rdd-we-have)
rows (spark/map trans/as-rows rdd)
dataframe (spark/create-data-frame sql-context rows schema)
]
(spark/save-parquert dataframe output-path :overwrite))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment