我想使用火花流处理来自kafka的事件,并希望根据消息数量而不是时间来设置窗口宽度和滑动条。这可能吗?我没有在api中看到任何明显的内容,只是看到了基于时间的窗口选项。Spark Streaming窗口宽度和滑动
0
A
回答
0
这是不可能的。您只能设置窗口持续时间。
0
这得到足够接近我想要的东西: [输出基于多个消息的具体时间内的事件] https://damieng.com/blog/2015/06/27/time-window-events-with-apache-spark-streaming
相关问题
- 1. Spark Streaming窗口输出
- 2. 窗口边框的宽度和高度
- 3. Flexslider适合窗口高度和宽度
- 4. 按钮宽度填满窗口宽度
- 5. dicom窗口中心,窗口宽度
- 6. Spark Streaming Multiple Streaming Jobs
- 7. WPF滑动窗口
- 8. 滑动窗口集
- 9. opencv滑动窗口
- 10. 滑动窗口seq
- 11. CustomControl滑动窗口
- 12. 动画窗口调整大小(宽度和高度)C#WPF
- 13. 试图窗口的宽度和高度设置为自动
- 14. 在C中获取活动窗口坐标和高度宽度#
- 15. jQuery的窗口的宽度和追加
- 16. CSS窗口宽度问题
- 17. JavaScript中的窗口宽度
- 18. 如何重置窗口宽度和窗口比例onload?
- 19. Silverlight宽度平滑动画
- 20. Apache Spark Streaming:通过密钥的窗口化PairDStream的中值
- 21. 调整大小时滑块重新计算窗口宽度
- 22. 自定义全宽度滑动滑块
- 23. Spark Streaming和Phoenix Kerberos问题
- 24. Spark-Streaming Kafka Direct Streaming API&Parallelism
- 25. Cordova mac默认窗口高度宽度
- 26. 实时获取窗口高度/宽度
- 27. 使用滑动窗口FFT
- 28. R data.table滑动窗口
- 29. ExtJs窗口滑动问题
- 30. 跳过滑动窗口
重复的问题。请参阅[this one](http://stackoverflow.com/questions/36711439/spark-streaming-scala-window-length-by-number-of-objects/36711807#36711807)了解详情。 –