1、Python on Flink & Flink on Zeppelin ?(?)&?(?) Staff Engineer Alibaba 04/22/2020 About Me 2016.10 Staff Engineer Alibaba Apache Flink 2017.7 Apache IoTDB Committer 2019.6 Apache Flink PMC 2020.1 Apache Flink Committer 2020.2 ALC Beijing Member 2020.4 ASF Member ? ? ? Apache Beam Committer ? Agenda ?
2、Why PyFlink ? Status of PyFlink ? Future of PyFlink ? Flink on Zeppelin PyFlink ? ? ? 85 ? ? ?PyFlink?PyFlink?CDN? ? ? ? ? PyFlink ? ? ? ? ? ? get_execution_environment(.) t_env.register_function(.) t_env.add_python_file(.) t_env.from_path(.) .group_by(.) .select(.) .insert_into(.) t_env.execute(.)
3、Py ? ? ? Py Logging State Data Metric State DataUDF ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? - BeamPy4J Python UDF Java PyFlink - PyFlink ? ? ? ? ? ? ? ? Table API/SQL Python VM Java VM Python UDF Dependency management User-Defined Function Python Lib V1.9 V1.10 Pandas Series/DataFrame Of Gelly API ML Pipeline API Python SQL Client Counters, Gauges, Meters V1.11 UDF Metrics Cython For Performance Tyak
1、下载报告失败解决办法 2、PDF文件下载后,可能会被浏览器默认打开,此种情况可以点击浏览器菜单,保存网页到桌面,就可以正常下载了。 3、本站不支持迅雷下载,请使用电脑自带的IE浏览器,或者360浏览器、谷歌浏览器下载即可。 4、本站报告下载后的文档和图纸-无水印,预览文档经过压缩,下载后原文更清晰。
Java与大数据架构:3. Large-scale near-real-time (NRT) data analytics platform empowered by Apache Flink - Ying Xu & Kailash Hassan Dayanand, Lyft.pdf
三个皮匠报告专业的行业报告下载站,每日更新,欢迎大家关注!
copyright@2008-2013 长沙景略智创信息技术有限公司版权所有 网站备案/许可证号:湘B2-20190120
专属顾问
机构入驻、侵权投诉、商务合作
三个皮匠报告官方公众号
验证即登录,未注册将自动创建三个皮匠报告账号
使用 微信 扫一扫登陆