是否可以提供特定事件在結構化流中接收的日期和時間?
沒有直接. 資料的源負責事件時間, <unk>到達<unk>時間通常是您正在讀取的訊息伺服器源 (卡夫卡,Kinesis等) 的時間<unk>, <unk>處理<unk>時間可以在使用函式包 current_timestamp 函式處理傳入資料流時插入. https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ 這不是Spark從伺服器接收資料的確切時間,但它接近,並將按觸發間隔分組. 請注意,在連續模式下不能使用此函式. https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#支援的查詢