We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 84e32c4 + 35a568b commit 6aff376Copy full SHA for 6aff376
07-SparkSQLTableDemo/src/main/scala/guru/learningjournal/spark/examples/SparkSQLTableDemo.scala
@@ -24,8 +24,9 @@ object SparkSQLTableDemo extends Serializable {
24
25
flightTimeParquetDF.write
26
.mode(SaveMode.Overwrite)
27
+ .format("csv")
28
//.partitionBy("ORIGIN", "OP_CARRIER")
- .bucketBy(5, "OP_CARRIER", "ORIGIN")
29
+ .bucketBy(5, "ORIGIN", "OP_CARRIER")
30
.sortBy("ORIGIN", "OP_CARRIER")
31
.saveAsTable("MY_DB.flight_data")
32
0 commit comments