在Flink中，流处理和批处理采用何种统一模型？请阐述Flink实现流批一体化的核心机制。

回答思路

1. 【回答框架 1】Flink将批处理视为有界流，流处理视为无界流，统一由DataStream API处理，这是其流批一体的根本前提。
2. 【回答框架 2】核心机制是统一的运行时和状态管理：Flink的流处理引擎天然支持有界数据源，批处理作业被当作流作业执行，但会进行特定优化。
3. 【回答框架 3】优化包括：批处理模式使用有界数据源、更高效的调度策略（如批量调度）、以及针对批作业的容错和恢复优化（如不进行checkpoint，依赖重放）。
4. 【回答框架 4】DataStream API与Table/SQL API均支持动态表概念，既可用于流也可用于批，实现统一的声明式处理。
5. 【回答框架 5】最终通过统一的API、执行引擎和状态管理，用户可用一套代码处理流与批，实现流批一体化。
6. 【关键点 1】流批一体基石是有界/无界流统一模型。
7. 【关键点 2】同一个DataStream或Table API可用于两种模式。
8. 【关键点 3】批处理模式触发特定优化，如批量调度和重放容错。
9. 【关键点 4】Table/SQL的动态表是流批统一的声明式接口。
10. 【易错点 1】不要认为流批一体意味着二者性能完全一致，批优化仍不可少。
11. 【易错点 2】不要混淆有界流与无界流的语义，状态和事件时间处理需区分。