Чи дає спалах дату та час, коли конкретна подія приймається в структурованому потоку?
Не безпосередньо Джерело даних відповідає за час події, час «прибуття» зазвичай є часовим штампом з джерела сервера повідомлень, з якого ви читаєте (Kafka, Kinesis тощо). час «обробки» можна вставити при обробці надходжуваного потоку даних за допомогою функції пакету функцій 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#supported-queries