apache beam是一个统一的模型，用于定义批处理和流数据并行处理管道，以及一组特定于语言的sdk，用于构建管道和运行程序，以便在分布式处理后端（包括apache apex、apache flink、apache spark、google cloud dataflow和hazelcast jet）上执行它们。