????????????????UDF????????????

Thu, 23 Sep 2021 04:42:10 -0700 

??????HBASE??????????kafka????userId??????OK????????????????????????


------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2021??9??23??(??????) ????7:13
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;??????????UDF????????????



Hi??????
&nbsp;&nbsp;&nbsp; ?????????????????????????? Flink ?? Kafka Topic 
???????????????????? Hbase
???????????????????????????????????????????? Hbase ?????????? Topic ???? userid 
??
Hbase????????Hbase??????????????????????????????????????????????????????????????6????????????6??????????????????????????????????????????????????
env.addSource(new FlinkKafkaConsumer011(...))
.map(message -&gt;(userid,actions))
.keyby(userid)
.process(new MyHbaseStateFunction)
.print()
&nbsp;&nbsp;&nbsp; ????????????????????Flink Sql 
??????????????????????????????????Flink UDF??????????????????????
keyby??????????????????userid??????????????????????????task????????????????????Flink
UDF????????????????????????????userid??????

回复