Flink提供的8种分区函数GlobalPartitioner该分区器会将所有的数据都发送到下游的某个算子实例(subtask id = 0) 12345678910111213// 数据会被分发到下游算子的第一个实例中进行处理 public static void global() ...

函数类比如说我们常用的MapFunction，FilterFunction，ProcessFunction等，每一步操作都基本上都对应一个Function。 12345678910public static class MyFlatMapper implements FlatMapFunct ...

Flink支持所有的Java和Scala基础数据类型以及其包装类型 支持Tuple元组类型，Flink在Java API中定义了很多Tuple的实现类，从Tuple0 ~ Tuple25类型 Scala样例类 case class，对应Java中的POJO类对象(必须提供无参构造方法 get ...

读取文件这里是以txt文件为例，实现WordCount，其他文件类型同理。 12345678910111213141516171819202122232425 public static void main(String[] args) throws Exception { ...

好了，看到这的话，Apache Flink基础概念啥的都应该了解差不多了吧，我们几天就See一下，平时用到的StreamApi中各式各样的算子都有什么，然后，我们搞点Demo试一下。 📒 我也是边学边实现一些Demo,这样呢可以方便自己理解，形成体系以后也应该能帮到别人快速学习吧。 这就是 ...

什么是窗口 窗口分配器有几种 窗口如何实现增量计算和全量计算

门面模式门面模式又叫做外观模式，提供统一的一个接口，用来访问子系统中的一群接口；门面模式定义了一个高层接口，让子系统更容易使用；门面模式属于结构型模式； 类图 Facade 门面类12345678910111213141516public class Facade { ...

适配器模式适配器模式（Adapter Pattern）又叫做变压器模式，它的功能是将一个类的接口变成客户端所期望的另一个接口，从而使得原本因接口不匹配而导致无法在一起工作的两个类能够在一起工作，属于结构性设计模式的一种； 在软件开发的过程中，基本上任何问题都可以通过一个中间层解决。适配器模式 ...

责任链模式责任链模式（Chain of Responsibility Patter）是将链中的每一个节点看成是一个对象，每个节点处理的请求均不相同，并且内部自动维护下一个节点对象。当一个请求从链的头部发出时，会沿着链的路径一次传递给每一个节点对象，直到有节点处理这个请求为止；责任链模式属于行 ...

观察者模式观察者模式指多个对象间存在一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式，它是对象行为型模式。 属于行为型模式 类图 ISubject12345678public interface I ...