This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 900908b [SPARK-36410][CORE][SQL][STRUCTURED STREAMING][EXAMPLES]
Replace anonymous classes with lambda expressions
add 004b87d [SPARK-36455][SS] Provide an example of complex session
window via flatMapGroupsWithState
No new revisions were added by this update.
Summary of changes:
.../JavaStructuredComplexSessionization.java | 461 +++++++++++++++++++++
.../StructuredComplexSessionization.scala | 301 ++++++++++++++
2 files changed, 762 insertions(+)
create mode 100644
examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredComplexSessionization.java
create mode 100644
examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredComplexSessionization.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
