Skip to content

Instantly share code, notes, and snippets.

@cesar1091

cesar1091/Ejercicio7.py

Created October 1, 2022 23:00
Show Gist options
  • Save cesar1091/5bfdf8ac9a940dcf4d87e6e7990a4b34 to your computer and use it in GitHub Desktop.
Save cesar1091/5bfdf8ac9a940dcf4d87e6e7990a4b34 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Ejercicio7.py
product = spark.read.format("csv").option("inferSchema","true").schema(ProductSchema).load("/public/retail_db/products/part-00000")
product.write.format("hive").saveAsTable("product")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment