昨天有位大哥问小弟一个Spark问题，他们想在不停Spark程序的情况下动态更新UDF的逻辑，他一问我这个问题的时候，本猪心里一惊，Spark**还能这么玩?我出于程序员的本...
发简信
IP属地：贵州
-
Spark - 动态注册UDF -
Flink总结Flink总结 Flink简介 Apache Flink作为一款高吞吐量、低延迟的针对流数据和批数据的分布式实时处理引擎，是当前实时处理领域的一颗炙手可热的新星 flink技...
-
python操作阿里云oss
这次的案例是利用阿里云oss2进行简单的bucket查询以及上传下载等基础操作 对象存储对象存储的概念我就不做太多概述了，详情可以参考阿里云 sdkpython的sdk不仅提...
-
数据分析实践 | flink | window窗口篇要弄懂flink全部的工作机制其实是一件比较麻烦的事情，零碎的概念太多，对于第一次接触flink的我也算是个挑战。 整体感受就是--看官方文档的过程就像在做高中的阅读理解：）...
-
Flink 的Window 操作
Flink的 Window 操作 Window是无限数据流处理的核心，Window将一个无限的stream拆分成有限大小的”buckets”桶，我们可以在这些桶上做计算操作。...
-
-
用GitLab的Merge Request做代码评审在目前已使用的质量内建的工程实践中不可否认的一个实践为代码审查 它被用作提高产品交付质量和提高开发过程效率的有效措施。 Git又是目前当红的源码管理工具，若你的团队目前已经选...
-
Presto查询队列配置
在你的presto安装目录下的/etc/config.properties添加 query.queue-config-file=/soft/presto-206/etc/qu...
