1. 面试官：Apache Beam 中的 ParDo 函数是如何工作的？详细解释其原理和内部实现。

2. 面试官：如何在 Apache Beam 中实现自定义的数据转换函数？请举例说明。

3. 面试官：Apache Beam 中的 Windowing 是什么？它在大规模数据处理中的作用是什么？

4. 面试官：如何处理 Apache Beam 中的数据重复问题？请提供多种解决方法并比较它们的优缺点。

5. 面试官：BeamSQL 是如何在 Apache Beam 中工作的？它与传统 SQL 有何异同？

6. 面试官：在 Apache Beam 中如何处理分布式计算中的数据水位线（Watermark）？

7. 面试官：如何实现在 Apache Beam 中实现数据的动态窗口分配？

8. 面试官：在 Apache Beam 中如何处理数据的多路输出（Multi-output）？请以实际案例说明。

9. 面试官：Apache Beam 中的 IO Connector 是如何实现数据源和数据接收的连接的？

10. 面试官：如何在 Apache Beam 中实现数据的紧急处理（Late Data Processing）？