Spark 如何生成一个空的DataFrame

@羲凡——只为了更好的活着

Spark 如何生成一个空的DataFrame

Q:Spark如何生成一个空的DataFrame
A:有两种情况,一种是没有列的DataFrame,一种是有列的DataFrame,情况2最实用

情况1.生成一个无列的空DataFrame
val df = spark.emptyDataFrame
情况2.生成一个有列的空DataFrame
// 生成一个空的三列DataFrame
val schema = StructType(
  Seq(
    StructField("lie1", StringType, true),
    StructField("lie2", StringType, true),
    StructField("lie3", StringType, true)))
val df = spark.createDataFrame(sc.emptyRDD[Row], schema)

大家可以参考此微博 https://blog.csdn.net/dkl12/article/details/81747908

====================================================================

@羲凡——只为了更好的活着

若对博客中有任何问题,欢迎留言交流