apache-spark - 如何在 reduceByKeyAndWindow 中设置具体的开始时间？
问题描述
我正在使用 Spark Streaming 并且正在使用 Kafka 主题，我还使用 reduceByKeyAndWindow 定义了一个流窗口，当我将例如 windowLength 10 秒和 slideInterval 10 秒放入时，我按预期每 10 秒得到结果，问题是我希望从特定时间开始每 10 秒显示一次窗口，在 00 秒，无论分钟，以便在 10、20、30 等我得到结果，因为现在我每 10 得到结果秒，但在一次执行中，窗口例如在 01、11、21 开始，而在另一次执行中，则在 09、19、29 等开始。
有谁知道我如何强制窗口在我想要的第二个开始？
谢谢！
解决方案
推荐阅读
- python - PostgreSQL 数据时间类型的最佳数据类型
- r - 在 R 中使用平衡设计分析重复测量
- docker - 无法从容器外部访问 Angular
- docker - 使用 Docker 映射 Compute Engine 中的端口
- c - C - 指向结构的指针 - 分段错误
- handlebars.js - handlebars.js - 遍历 json 数组以确定是否应选中复选框
- c# - Web API 2 中的依赖注入服务授权
- c# - MVC ActionResult 模型似乎正在使用缓存视图
- typescript - 将字符串转换为 NSData 并将 NSData 转换回字符串
- c# - C# - 循环并获取具有相同名称的 XML 值的值