DataStream API是Flink用于数据处理的API。是对有界数据和无界数据处理的API。 DataS… 继续阅读 Flink从入门到实战四[DataStream API]-1-DataStream API简介
分类： 编程之美
发现编程语言之美，体验代码简洁之道，分享各类编程教程，技术心得分享
Flink从入门到实战三[架构]-1_Flink运行时架构
Flink 运行时由两种类型的进程组成：一个 JobManager 和一个或者多个 TaskManager。 … 继续阅读 Flink从入门到实战三[架构]-1_Flink运行时架构
Flink从入门到实战二[部署]-1-Flink Standalone集群部署
前面章节已经过单机Standalone模式，接下来我们看一下Standalone的集群模式部署。我们以官网部署… 继续阅读 Flink从入门到实战二[部署]-1-Flink Standalone集群部署
Flink运行报错：java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction
本地IDE运行Flink代码，报错如下： 问题解决：问题出在pom文件中，其中引入的Flink包的scope为… 继续阅读 Flink运行报错：java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction
Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性，但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3
Flink从入门到实战一[快速上手]-7-Flink官方反欺诈项目版本2
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性，但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink从入门到实战一[快速上手]-7-Flink官方反欺诈项目版本2
Flink实战学习1[快速上手]-6-Flink官方反欺诈项目版本1
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性，但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink实战学习1[快速上手]-6-Flink官方反欺诈项目版本1
Flink从入门到实战一[快速上手]-5-Flink HelloWorld之流处理WordCount-Socket
flink中的数据分为有界流数据和无界流数据，对应的处理计算叫做批处理和流处理，批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-5-Flink HelloWorld之流处理WordCount-Socket
Flink从入门到实战一[快速上手]-4-Flink HelloWorld之流处理WordCount
flink中的数据分为有界流数据和无界流数据，对应的处理计算叫做批处理和流处理，批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-4-Flink HelloWorld之流处理WordCount
Flink从入门到实战一[快速上手]-3-Flink HelloWorld之批处理WordCount
flink中的数据分为有界流数据和无界流数据，对应的处理计算叫做批处理和流处理，批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-3-Flink HelloWorld之批处理WordCount
Flink从入门到实战一[快速上手]-2-Flink本地模式安装
运行Flink的前提，需提前安装好 Java 8 或者 Java 11。 1：下载并解压下载地址：https:… 继续阅读 Flink从入门到实战一[快速上手]-2-Flink本地模式安装
Flink 1.14.3从入门到实战一[快速上手]-1-Apache Flink是什么
Apache Flink 是什么？我们来看一下官方的解释。Apache Flink 是一个框架和分布式处理引擎… 继续阅读 Flink 1.14.3从入门到实战一[快速上手]-1-Apache Flink是什么
Linux系统配置JDK环境变量
1、下载JDK 自行到Oracle网站下载对应的JDK版本：www.oracle.com 2、解压 下载对应的… 继续阅读 Linux系统配置JDK环境变量
Git常用命令
常用命令 文件操作 分支操作 Tag 撤销/恢复
git提交问题：码云remote: error: File: , exceeds 100.00 MB
使用码云作为代码版本库，提交文件是报错：remote: error: File: , exceeds 100.… 继续阅读 git提交问题：码云remote: error: File: , exceeds 100.00 MB
Java并发编程CAS类的使用
Java多线程累加，是并发编程的入门代码，一般是通过Synchronized同步方法来保证多线程累加结果的正确… 继续阅读 Java并发编程CAS类的使用
并发编程可见性六原则:Happens-Before 规则
并发编程中，多线程共享变量之间的可见性，可以总结为六项 Happens-Before 规则（可见性规则）。 H… 继续阅读 并发编程可见性六原则:Happens-Before 规则
Java线程的生命周期
Java 中线程的生命周期:Java 语言中线程共有六种状态，分别是： NEW（初始化状态） RUNNABLE… 继续阅读 Java线程的生命周期
多线程 Exception in thread “main” java.lang.IllegalMonitorStateException
调试多线程代码的时候，运行代码，报错如下： 我是要模拟多线程并发创建单例对象，看看是否最终获取的是同一对象，结… 继续阅读 多线程 Exception in thread “main” java.lang.IllegalMonitorStateException
Java并发编程可见性bug和demo示例
Java并发编程导致bug的因素有三个：原子性、可见性和有序性。 我们这里用一个demo来看一下可见性的问题。… 继续阅读 Java并发编程可见性bug和demo示例