目的

流表互转 而且流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.$;/*** 流转