零、序言 本篇文章探究Flink Window窗口机制，首先介绍窗口机制使用的总纲，涉及的所有组件进行介绍，心中有一个大体的蓝图和认识。之后基于keyBy方法返回的Keyed...
发简信
IP属地：北京
-
Flink window窗口机制探究--以tumbling windows为例(一)
-
通过Flink 程序模板来学习StreamExecutionEnvironment 、DataStream 、StreamTransformation类
一、回到起点 一切都从最初的起点开始，我们来看官网给出的Flink Job程序的框架： 首先我们要创建StreamExecutionEnvironment，这是我们的流计算执...
-
Flink 实时指标计算之AggregateFunction计算事件发生次数和累计值
一、目标 数据源为Kafka ，通过Flink 时间窗口AggregateFunction方法来进行特定窗口内消息事件的次数和累计值。 本例中：使用事件时间（Event Ti...
-
Redis基础--基本数据类型
0 Redis 介绍 0.1 基础知识 不仅仅是简单的key-value数据库，更是一个in-memory data structure store。不仅仅支持简单的Stri...
-
Intellij ide+sbt+Flink+scala Windows开发环境配置(离线无网络)近期在无网络环境内网 Window 环境配置 Flink开发环境，很艰苦。由于准备使用Scala，根据官网Flink推荐使用sbt 来进行配置管理，使用Intellij id...
-
微信公众号python爬虫之总体概况这两天看公众号回顾之前的文章，有些文章发现已经被删甚至有些公众号直接被屏蔽了。甚是可惜，想着可以做一个微信公众号的爬虫来爬取文章保存到本地。 v0.1 功能 针对特定公众号已...
-
Flink1.7.2 ZDH 集群 Standalone 模式独立配置JDK1.8 小记
背景 实验室环境能够申请的环境就是ZDH中兴的R4B4集群，尚未能支持Flink组件。根据咨询ZDH工程师，最新版本的应该已经有Flink组件了，但是仍然是实验性质，并不会立...
-
写给艺考生妹妹的高考动员--关于文化课复习的一些见解（二）
接上文写给艺考生妹妹的高考动员--关于文化课复习的一些见解（一） 数学嘛， 数学本来就是美的化身和代表！ 一行行公式凝聚的是人类伟大的智慧结晶啊！集合、函数、几何、统计概率。...
-
写给艺考生妹妹的高考动员--关于文化课复习的一些见解（一）
前些日子跟艺考生妹妹的聊天，动员吧，主要是谈了谈自己对高考各门课的见解，可能会有偏颇，可能没有对症下药。也算高考动员吧，第一篇主要包括：地理、历史和政治。各位高考同学都有好的...
-
用 docker 来搭建独立的 jupyter 环境
近期接触docker ，感觉容器真是好东西，需要什么开发环境就搞一个对应镜像，docker运行起来就可以用了，简单快捷，不让自己的本子变成一个有各种开发环境的大杂烩。搭建独立...
