我正在執行 的輸出，readStream format("rate")我想獲取dataframe. 我在檔案中truncate找到的唯一選項是，但我找不到如何強制獲得類似的東西
Batch: 3
-------------------------------------------
----------------------- ---------
|timestamp:String |value:Int|
----------------------- ---------
|2021-10-14 14:28:58.981|0 |
----------------------- ---------
而不是那個
Batch: 3
-------------------------------------------
----------------------- -----
|timestamp |value|
----------------------- -----
|2021-10-14 14:28:58.981|0 |
----------------------- -----
輸出代碼為：
df
.writeStream
.format("console")
.option("truncate", "false")
.start().awaitTermination(20000)
uj5u.com熱心網友回復：
感謝@m_vemuri
解決辦法是
println("Rate schema:")
println(rate.schema.fields.mkString)
從那以后，我知道為rate產生的型別是什么value：
Rate schema:
StructField(timestamp,TimestampType,true)StructField(value,LongType,true)
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/322631.html
標籤：斯卡拉 阿帕奇火花 apache-spark-sql 火花流
下一篇：java.lang.ClassNotFoundException：無法找到資料源：org.apache.bahir.sql.streaming.mqtt.MQTTStreamSinkProvider。