flink1.18.0 流转表 表转流 jdk17 attachAsDataStream

本文主要是介绍flink1.18.0 流转表 表转流 jdk17 attachAsDataStream，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目的

流表互转 而且流sink 表sink同时存在且都可以输出.

依赖类

package flink.luca.flinkTableAndSQL.Convert;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;@Data
@AllArgsConstructor
@NoArgsConstructor
public class Outer1 {Integer outerId;Inner1 inner1;
}

package flink.luca.flinkTableAndSQL.Convert;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;@Data
@AllArgsConstructor
@NoArgsConstructor
public class Inner1 {Integer innerId;String name;
}

code

package flink.luca.flinkTableAndSQL.Convert;import lombok.val;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;import static org.apache.flink.table.api.Expressions.$;/*** 流转

这篇关于flink1.18.0 流转表 表转流 jdk17 attachAsDataStream的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---