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.$;

/**
 * 流转

原文地址：https://blog.csdn.net/qq_35515661/article/details/137871034

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！