Flink常用API之转换算子的union算子

Flink常用API之转换算子的union算子

package transformationimport org.apache.flink.streaming.api.scala.StreamExecutionEnvironment/** * @Author yqq * @Date 2021/12/26 16:07 * @Version 1.0 */object Transformation { def main(args: Array[String]): Unit = { val en = StreamExecutionEnvironment.getExecutionEnvironment en.setParallelism(1) import org.apache.flink.streaming.api.scala._ val stream1: DataStream[(String, Int)] = en.fromElements(("a", 1), ("b", 2)) val stream2: DataStream[(String, Int)] = en.fromElements(("c", 3), ("d", 4)) val result: DataStream[(String, Int)] = stream1.union(stream2) result.print() en.execute() }}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。