-
- Downloads
[SPARK-16114][SQL] structured streaming event time window example
## What changes were proposed in this pull request? A structured streaming example with event time windowing. ## How was this patch tested? Run locally Author: James Thomas <jamesjoethomas@gmail.com> Closes #13957 from jjthomas/current.
Showing
- examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java 2 additions, 2 deletions...xamples/sql/streaming/JavaStructuredNetworkWordCount.java
- examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCountWindowed.java 116 additions, 0 deletions...sql/streaming/JavaStructuredNetworkWordCountWindowed.java
- examples/src/main/python/sql/streaming/structured_network_wordcount.py 2 additions, 1 deletion...main/python/sql/streaming/structured_network_wordcount.py
- examples/src/main/python/sql/streaming/structured_network_wordcount_windowed.py 102 additions, 0 deletions...on/sql/streaming/structured_network_wordcount_windowed.py
- examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredNetworkWordCount.scala 1 addition, 1 deletion...k/examples/sql/streaming/StructuredNetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredNetworkWordCountWindowed.scala 103 additions, 0 deletions...es/sql/streaming/StructuredNetworkWordCountWindowed.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala 38 additions, 9 deletions...ala/org/apache/spark/sql/execution/streaming/socket.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/TextSocketStreamSuite.scala 51 additions, 1 deletion...spark/sql/execution/streaming/TextSocketStreamSuite.scala
Loading
Please register or sign in to comment