我正在尝试创建小的apachebeam流式程序来测试想法，我认为获取数据最简单的方法就是使用框架结构，比如 Create.of 制造假数据。那样的话，我就不需要设置更多的内容，比如设置gcp发布/子主题作为源并发布到它。
问题是我想尝试一些基于时间的东西，比如窗口和使用状态和计时器。我能把这些放在一起：

public class TestPipeline {
    public static void main(String[] args) {
        PipelineOptions options = PipelineOptionsFactory.create();
        Pipeline p = Pipeline.create(options);

        p.apply(Create.of(1, 2, 3))
            .apply(ParDo.of(new DoFn<Integer, String>() {
                @ProcessElement
                public void processElement(ProcessContext c) {
                    c.output(c.element().toString());
                }
            }))
            .apply(TextIO.write().to("myfile.txt"));

        p.run().waitUntilFinish();
    }
}

这实现了我在管道开始时发送三条数据的目标，但它同时发送了所有数据。我更希望能设置为每10秒发送一次数据，等等。
我遵循了apache flink的教程(https://ci.apache.org/projects/flink/flink-docs-release-1.10/getting-started/walkthroughs/datastream_api.html)这是我想要完成的一个例子。我深入研究了那个教程中的代码，但我无法确切地找出flink框架的哪一部分实现了这一点。