参考1参考2参考3参考4参考5 推送： 服务器给客户端发送消息开发者通过第三方推送服务提供商将信息直接下发给需要的设备，第三方推送服务提供商与设备建立一条长连接通道，并且将消...
发简信
IP属地：北京
-
IM+推送+心跳机制 -
Flink1.11升级填坑
背景 现有集群版本是Flink 1.10.1，想要升级到社区最新的版本Flink 1.11.1. 踩坑过程 No hostname could be resolved for...
-
Kettle下载和安装Kettle简介：Kettle 是 PDI 以前的名称，PDI 的全称是Pentaho Data Integeration，Kettle 本意是水壶的意思，表达了数据流的含义...
-
python中defaultdict用法详解
认识defaultdict： 当我使用普通的字典时，用法一般是dict={},添加元素的只需要dict[element] =value即，调用的时候也是如此，dict[ele...
-
Flink实战—Flink SQL在Batch场景的Demo最近工作会用到Flink SQL，周末学习了一下，写个demo做记录，全部代码请参考Github. 基于的Flink版本是1.9.1，使用的是java8开发。 本例是Flin...
-
Parquet 实践和基本原理生成一个parquet文件 下载 编译 运行 准备csv文件 生成parquet文件 可见目录下多了一个sample.parquet文件。这里没有指定avsc格式的schem...
-
使用Flink完成流数据统计一、统计流程 所有流计算统计的流程都是：1、接入数据源2、进行多次数据转换操作(过滤、拆分、聚合计算等)3、计算结果的存储其中数据源可以是多个、数据转换的节点处理完数据可以发...
-
聊聊flink如何兼容StormTopology
序 本文主要研究一下flink如何兼容StormTopology 实例 这里使用FlinkLocalCluster.getLocalCluster()来创建或获取FlinkL...
