2016-04-21 104 views
0

我想使用火花流处理来自kafka的事件,并希望根据消息数量而不是时间来设置窗口宽度和滑动条。这可能吗?我没有在api中看到任何明显的内容,只是看到了基于时间的窗口选项。Spark Streaming窗口宽度和滑动

+1

重复的问题。请参阅[this one](http://stackoverflow.com/questions/36711439/spark-streaming-scala-window-length-by-number-of-objects/36711807#36711807)了解详情。 –

回答

0

这是不可能的。您只能设置窗口持续时间。