Flink的算子 目录 Flink的算子 1、Map 2、FlatMap 3、Filter 4、KeyBy 5、Reduce 6、Aggregations 7、Window 8、Union ...

策略模式是设计模式中很重要的一种，它的主要意图就是：定义了算法族，分别封装起来，让它们之间可以互相替换。它让算法的变化可以独立于使用算法的客户，使得我们可以随时更改它们而不影响客户端的代码 ...

2. Flink 的 DataSource 数据源 4) 自定义 Source 当然也可以自定义数据源，有两种方式实现： 通过实现 SourceFunction 接口来自定义无并行度（也就是并行度只能为 1）的 Source。 通过实现 ...

flink的keyby算子作用是把相同key的数据发送到一个分区（即一个subtask里面去），采用的是哈希分区方法。 用法多样，主要整理了下图中的四种用法。 第一种是 key(Interger) 用法，传入一个整数，这个整数对应的是元组中的元素顺序是第几个，（注：可以是多个key,不一定 ...

一、Connect DataStream,DataStream -> ConnectedStream，连接两个保持他们类型的数据流，两个数据流被Connect之后，只是被放在了同一个流中，内 ...

前言 本文首发自https://www.cnblogs.com/slankka/ 转载请注明出处。 本文的主要内容是介绍如何动态加载Flink作业的UDF。 Classloader 加载UDF一定是classLoader做的，而作业启动的过程中，App ClassLoader的具体实现类 ...

借用官网的一个例子： Flink 开发的时候，经常会遇到这种情况，数据的输入源有多个，需要将一些流先关联起来（比如：清洗规则、动态配置），再做后续的计算。 对于这样的场景，可能很容易就想到使用 join api ，直接将两个流 join 起来。 实际上，这样个需求，使用 ...

首先，查看要修改的oracle参数的属性（动态or静态） SQL> select name,value,isses_modifiable,issys_modifiable from V$PARAMETER where name='max_dump_file_size'; 注 ...