Table Api & SQL连续查询Join

该文章主要是对Flink官网相关内容进行翻译,原文地址:https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/time_attributes.html Join是批处理数据处理中常见且易于理解的操作,用于连接两个关系的行。 但是,动态表上的连接语义不太明显甚至令人困惑。 在Flink中有几种方法可以使用Table API或SQL实际执行连接。 对于文章中的时间属性和时态表请参考笔者之前文章。 常规JOIN 常规联接是最通用的join类型,其中任何新记录或对join输入两侧的任何更改都是可见