图解 Flink 滚动窗口、会话窗口和滑动窗口

1.2k 记录 发表评论
1. Flink 窗口是什么? Flink 作业中的窗口是指一种对无限数据流设置有限数据集,从而实现了处理无线数据流的机制。 窗口本身只是个划分数据集的依据,它并不存储数据。 当我们需要在时间窗口维度上对数据进行聚合时,窗口是流处理应用中经常需要解决的问题。Flink的窗口算子为我们提供了方便易用的API,我们可以将数据流切分成一个个窗…

Flink 入门教程

359 记录 发表评论
不得不说,Flink 这两年是真的火🔥这篇文章主要讲讲Flink入门时一些可能看不太懂的点又或是看官方介绍看不太懂的点(API我就不细说了,多用用应该都能看懂)。 1. 什么是Flink? 在Flink的官网上,可以把官方文档语言设置为中文,于是我们可以看到官方是这样介绍的: 上面的图我们每个字都能看得懂,但连起来就看不懂了。 不管怎…

docker-compose 搭建 Flink 环境

689 记录 发表评论
docker-compose 介绍 docker-compose 是一个用来把 docker 自动化的东西。 有了 docker-compose 你可以把所有繁复的 docker 操作全都一条命令,自动化的完成。 用通俗的语言来说,我们平时操作 docker 还是很原始的一系列动作,你手动使用 docker 的动作可以拆分成: 找到一个系统镜像 // docker search 安装好 vm 或者 virtual box // …

什么是子网掩码?

251 记录 发表评论
什么是子网掩码? 子网掩码是一个用于计算 IP 构成的数字。 一个 IP 由 2 个部分构成:网络标识和主机标识,子网掩码的作用,就是把这两个部分区分开。 因为 IPv4 是一个 32 位数字,所以子网掩码也是 32 位数字。 子网掩码是 IPv4 中的一个概念,在 IPv6 中已经不存在这一概念。 网络标识 假设,我的主机 IP 是 192.168.1.100,我如何…

Nginx 集成 GeoIP2 限制网站可访问的国家或区域

749 记录 发表评论
这里以 CentOS 系统为例。 1 安装 libmaxminddb 下载最新的 aeris-release rpm,三个命令依次对应CentOS6/7/8 yum -y install https://repo.aerisnetwork.com/pub/aeris-release-6.rpm yum -y install https://repo.aerisnetwork.com/pub/aeris-release-7.rpm dnf -y install https://repo.aerisnetwork.com/pub/aeris-release-8.rpm 再…

Java JNI 编程

364 记录 发表评论
本文会解决几个问题。 JDK 包中的 include/ 目录下的.h头文件有什么用? 如何用 C 语言编写一个 Java 可以调用的函数? Java 如何调用 C 语言编写的方法? 1 简介 有时候,我们需要用更底层的 C 或者 C++ 语言来实现 Java 难以实现的功能,比如克服 Java 中的内存管理和性能限制。 Java 提供了本机接口(Java Native Interface,也叫JN…

小米手机刷欧版系统

2.1k 记录 发表评论
1 准备 下载解锁工具(只有windows版,没有Linux和Mac版,所以建议用Windows系统刷机)下载欧版 MIUI ROM 包(注意,这个下载后不需要解压,直接用zip包)下载 Andriod Debug Bridge (ADB) SDK下载第三方 Recovery TWRP 2 解锁手机 注意:这里必须用电脑USB2.0端口,3.0需要强制转为2.0协议,具体参考后面。 首先在手机处于开机状态下…

Flutter(Dart) 解析嵌套 JSON 为 model 对象的问题解决

1.3k 记录 发表评论
最近在些 Flutter 应用时,用到了 GraphQL 分页,返回来的数据大概长下面这个样子,是按 Github API v4 的数据格式来整的: {"users":{ { "edges": [ { "node": { "id": "1", "name": "ZhangSan" }, "cursor": "MA==" }, { "node": { "id": "2", "name": "Lisi" }, "cursor": "MB==" } ], "pageInfo": { "hasNextPage": true, "hasPrev…

解决 flutter run 很慢或者下载 gradle 错误:Exception in thread “main” java.net.SocketException: Connection reset

451 记录 发表评论
这个问题是因为国内网络无法正常下载 gradle 引起的,不管你是啥版本,都一样。 详细的错误如下: [ +176 ms] Downloading https://services.gradle.org/distributions/gradle-6.7-all.zip [+5206 ms] Exception in thread "main" java.net.SocketException: Connection reset [ ] at java.net.SocketInputStream.read(SocketInputStre…
« 上一页   下一页 »