df_1 = df.rdd.map(lambda r: r).zipWithIndex().toDF(['value', 'index'])df_2 = spark.sql("select value.value as value , index from linenumber")
df_2.createOrRepla
下面的查询结果值是单行值,或者是ExtendedText的值,或者是表数据中匹配LineNumber的零值。我需要在查询中再添加一个条件,就像--如果LineNumber不存在,在null的情况下,将一行作为零返回。(dec,DeliveryPaymentExtras.ExtendedText)),0) As ExtendedTextWHERE (LineNumber=21) group by LineNumber