当前位置 博文首页 > 大风起兮云飞扬:Flink--持久层和Flink进行集成使用
?采用Flink对实时数据操作, 比如更新或者一些特定的操作等;然后将数据保存;
保存的操作有原生jdbc连接;? jpa或者Mybatis,Hibernate等;
思路A:
?1 启动Spring项目,然后自动注入一些service或者dao;
?2 Flink程序监听Spring项目是否启动完毕,启动完毕则启动Flink程序;
? ? ?结果:经过测试,Flink的程序是独立的,因为它是本地环境进行启动,JVM跟它单独分配空间执行;所以它与Spring这两个程序是独立的;Flink程序不能获取到Spring管理的实例;?
思路B:Flink启动并单独加载配置,例如hibernate,mybatis,原生jdbc的连接等;在Flink的进程中去启动配置获取连接等;
cs