??????????????????????????????????????????????????
1.??????????4??????????sink??????????????collect??????????????????????????????sink?????????? ????readfromkafka??????????????????collect?????????? 2.??????????????sinkdb??????????????????????????????????????????????????list,?????????????? ??????????????keyselecter????????????????????timewindow??????keyby????????????????????????????????????????????1???????? 3.??????????5????????????????????????????????????10??????????????????8??????????????????????2??????????????????????????????????2???????????????????? ??????????????keyselecter,??????????????????????????????????????10???????????????????????????? ????????IO????????????????????????????????????????????????????DB??????????????????????sink?????????? ??????????????????keyselecter??flink??????key????hash????????????????????Operator?? Sent from Mail<https://go.microsoft.com/fwlink/?LinkId=550986> for Windows 10 ________________________________ From: 1900 <[email protected]> Sent: Tuesday, April 23, 2019 11:27:47 AM To: user-zh Subject: ??????RE: flink?????????????? ------------------ ???????? ------------------ ??????: "Shi Quan"<[email protected]>; ????????: 2019??4??23??(??????) ????10:02 ??????: "[email protected]"<[email protected]>; ????: RE: flink?????????????? ???????????????????????????????????????????????? ???????????????????????????????????????????????????????????????????????? ?????????????????? 1. ????????????????????????????operator??????????????????????????????????????????????????????????????????????????????????????????????????chain???????????????????????????????? 2. ??kafka??????????you are right????????source?????????????????????????????????? 3. kafka source???????????????????????????????????????????????????????? 4. & 5 ?????????????????????????????? Sent from Mail<https://go.microsoft.com/fwlink/?LinkId=550986> for Windows 10 ________________________________ From: 1900 <[email protected]> Sent: Tuesday, April 23, 2019 9:47:08 AM To: user-zh Subject: flink?????????????? ????flink????????????????1.7.2??hadoop??????2.8.5,????flink on yarn ha?????????????????? run a job on yarn ??????????????????kafka??????????????window??????????????????5??????????????????list??????????????????????????db 1.?????????????????????????????????????? 2.????kafka????????????????????????????topic????????????????topic??8??????????????????8???? ???????????????????????? 3.??????????????????????kafka??????????????????????????????????????????????window???????????????????? ????????????kafka??????????????????????4????????????????????kafka??????????????????????????kafka??????????1???? ??????????????????????????????????????????kafka???????????????????????????????????? 4.????????????????????key????????????????????ID??????hash?????????????????????????? ??????????????????kafka???????????????????????????????????? ??????DB??????????????????????????????????????????????????????????????????????????????kafka?????????????????????????? 5.????????????????key????????????????????????????????????????????????slot????????????????????????8??????????????????6???????????????????? ??2????????????????????????????????????????????????????????????????
