Generate windows on processing time in Spark Structured Streaming

2017-11-10 Thread wangsan
Hi all, How can I use current processing time to generate windows in streaming processing? window function's Scala doc says "For a streaming query, you may use the function current_timestamp to generate windows on processing time.” But when using current_timestamp as column in window

Unsubscribe

2018-02-09 Thread wangsan
- To unsubscribe e-mail: user-unsubscr...@spark.apache.org