Java知识分享网 - 轻松学习从此开始!    

Java知识分享网

Java1234官方群25:java1234官方群17
Java1234官方群25:838462530
        
SpringBoot+SpringSecurity+Vue+ElementPlus权限系统实战课程 震撼发布        

最新Java全栈就业实战课程(免费)

springcloud分布式电商秒杀实战课程

IDEA永久激活

66套java实战课程无套路领取

锋哥开始收Java学员啦!

Python学习路线图

锋哥开始收Java学员啦!
当前位置: 主页 > Java文档 > 大数据云计算 >

基于Flink构建实时数据仓库 PDF 下载


分享到:
时间:2021-03-04 10:02来源:http://www.java1234.com 作者:转载  侵权举报
基于Flink构建实时数据仓库 PDF 下载
失效链接处理
基于Flink构建实时数据仓库 PDF 下载


本站整理下载:
提取码:lgwz 
 
 
相关截图:
 
主要内容:

public class UserDimFunc extends TableFunction<Tupl.e2<String, String» { private Map<String, Userlnfo> userDimCache = new HashMap<>();
色 Override
public void open(Functioncontext context) throws Exception { TimerTask repeatedTask = new TimerTask() {
public void run() {
// connect to mysql/hive
// userDimCache =...
}
};
Timer timer = new Timer( name: "LoadTimer"); timer.scheduleAtFixedRate(repeatedTask, delay: 0, period: 3600000L);
}
©Override
public Typeinformation<Tuple2<String, String» getResultType() return lypes.TUPLE(Types.STRING, Types.STRING);
}
public void evaKString id) { Userinfo user = userDimCache.get(id); if (user != null) {
collect(new Tuple2<>(user.name, user.region));
}
}
}


 

------分隔线----------------------------

锋哥公众号


锋哥微信


关注公众号
【Java资料站】
回复 666
获取 
66套java
从菜鸡到大神
项目实战课程

锋哥推荐