Open marchboy opened 4 years ago
https://marchboy.github.io/2020/10/20/Spark%E7%AC%94%E8%AE%B0-%E7%8E%A9%E8%BD%ACSparkSQL/#more
DataFramesGenerate创建一个RDD对象stringRDD,然后通过spark.read.json将stringRDD转换为DataFrame。 1234567891011121314151617181920stringJSONRDD = sc.parallelize((""" { "id": "123&quo
https://marchboy.github.io/2020/10/20/Spark%E7%AC%94%E8%AE%B0-%E7%8E%A9%E8%BD%ACSparkSQL/#more
DataFramesGenerate创建一个RDD对象stringRDD,然后通过spark.read.json将stringRDD转换为DataFrame。 1234567891011121314151617181920stringJSONRDD = sc.parallelize((""" { "id": "123&quo