wangsan created SPARK-22503:
-------------------------------
Summary: Using current processing time to generate windows in
streaming processing
Key: SPARK-22503
URL: https://issues.apache.org/jira/browse/SPARK-22503
Project: Spark
Issue Type: Improvement
Components: Structured Streaming
Affects Versions: 2.3.0
Reporter: wangsan
There are cases we want to use processing time to generate windows in stream
processing, but `current_timestamp()` are not allowed in `window()` function
now.
When using `current_timestamp` in `window` function, the exception tells
"nondeterministic expressions are only allowed in Project, Filter, Aggregate or
Window".
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
