Hmmm, we should allow that. current_timestamp() is acutally deterministic
within any given batch. Could you open a JIRA ticket?
On Fri, Nov 10, 2017 at 1:52 AM, wangsan wrote:
> Hi all,
>
> How can I use current processing time to generate windows in streaming
> processing?
> *window* function
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 functio