[ 
https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315675#comment-17315675
 ] 

Matthias J. Sax commented on KAFKA-12344:
-----------------------------------------

Sound about right – in the Java code, `windowedBy(SlidingWindows)` returns a 
`TimeWindowedKStream` and thus the Scala code should do a similar thing.

> Support SlidingWindows in the Scala API
> ---------------------------------------
>
>                 Key: KAFKA-12344
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12344
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>    Affects Versions: 2.7.0
>            Reporter: Leah Thomas
>            Priority: Major
>              Labels: newbie, scala
>
> in KIP-450 we implemented sliding windows for the Java API but left out a few 
> crucial methods to allow sliding windows to work through the Scala API. We 
> need to add those methods to make the Scala API fully leverage sliding windows



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to