Re: flink sql DDL支持 Temporal Table 定义吗

2020-06-14 文章 Leonard Xu
> 在 2020年6月15日,10:51,Zhou Zach 写道: > > 是不是说在flink sql JDBC Connector DDL中,加上这三个配置项,那么创建的表就是Temporal > Table,可以在temporary join 中使用? Hello 这三个参数是optional的,只是lookup cache的参数,通过配置这三个参数,在做维表jion时可以在性能和维表更新实效性之间进行配置,并不是配置了这三个参数就是维表。因为JDBCSource实现了LookUpSource 接口, 同时也实现了StreamTableSource 接口,

flink sql DDL支持 Temporal Table 定义吗

2020-06-14 文章 Zhou Zach
根据文档https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/joins.html#join-with-a-temporal-table, 临时表table source 必须要继承LookupableTableSource, 但是,看到https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#jdbc-connector -- lookup options,