如何写一个分区镶木地板文件在阿帕奇梁java

提问者：小点点

我是Apache Beam的新手，不知道如何完成这项任务。我想在Java中使用Apache Beam编写一个分区拼花文件。数据从Kafka读取，我希望文件每小时有一个新的分区。时间戳列存在于数据中。

共1个答案

匿名用户

尝试为此使用FixedWindows。有一个窗口WordCount的示例，它将每个窗口写入单独的文本文件-因此，我相信它可以适应您的情况。