概览执行模式(流/批)事件时间用户自定义 Functions状态与容错算子数据源旁路输出Handling Application Parameters测试实验功能Scala API 扩展Java Lambda Expressions管理执行