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.$;
 
/**
 * 流转