Apache Flink 漫谈系列(11) - Temporal Table JOIN

在Table中添加了createTemporalTableFunction方法，该方法需要传入时间属性和主键，接口定义如下：

// Creates TemporalTableFunction backed up by this table as a history table. 
 
def createTemporalTableFunction( 
timeAttribute: Expression, 
primaryKey: Expression): TemporalTableFunction = { 
...} 

用户通过如下方式调用就可以得到一个TemporalTableFunction的实例，代码如下：

val tab = ... 
val temporalTableFunction = tab.createTemporalTableFunction('time, 'pk) 
... 

3. 案例代码

(1) 需求描述

假设我们有一张订单表Orders和一张汇率表Rates，那么订单来自于不同的地区，所以支付的币种各不一样，那么假设需要统计每个订单在下单时候Yen币种对应的金额。

(2) Orders 数据

(3) Rates 数据

（编辑：青岛站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!