Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val schema = StructType(Seq(
- StructField("field1", StringType, true),
- StructField("field2", StringType, true)
- ))
- val df = spark.read.format("parquet").schema(schema).load(someReadPath)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement