1. 面试官：Apache Beam 的数据模型是如何实现水印和窗口操作的？

2. 面试官：请解释 Apache Beam 中的 DoFn（Do Function）及其作用？

3. 面试官：Apache Beam 中的 ParDo 和 Map 之间有什么区别？

4. 面试官：如何在 Apache Beam 中实现自定义的窗口操作？

5. 面试官：对于流式数据处理，Apache Beam 如何处理延迟数据和乱序数据？

6. 面试官：请解释 Apache Beam 中的触发器（Triggers）及其作用？

7. 面试官：Apache Beam 中的 side inputs 是什么？如何使用它们？

8. 面试官：如何在 Apache Beam 中实现自定义的 Aggregator 函数？

9. 面试官：Apache Beam 如何处理数据流中的异常情况？

10. 面试官：请解释 Apache Beam 中的数据并行化（Data Parallelism）和任务并行化（Task Parallelism）的区别和应用场景？