yayooo

2.1机器学习三要素 模型+策略+算法 模型：总结数据的规律，用数学语言描述参数系统 策略：选取最优的评价准则 算法：选取最优模型的具体方法 2.2 机器学习方法分类 2.2...

yayooo

1.下载安装miniconda 并且将 D:\app\miniconda\condabin 加入环境变量（path） 2.vscode 选择cmd终端，不选powershel...

yayooo

一.pom.xml 二、测试代码 三、常见的坑 3.1 pom文件的scala版本和idea手动导入版本不一致 pom.xml 的scala版本是 2.11修改办法是： 冲突...

yayooo

代码：

yayooo

背景 Flink LookupTableSource 通过使用流数据的一列或者多列的值，加载外部存储数据（维表数据），进而完成对流数据的字段扩展。在维表数据不频繁变更的情况下...

yayooo

一、数据传输形式 Stream在算子之间传输数据的形式可以是one-to-one(forwarding)的模式也可以是redistributing的模式，具体是哪一种形式，取...

yayooo

一、介绍 所有的Flink程序都是由三部分组成的： Source 、Transformation 和 Sink。 Source 负责读取数据源，Transformation...

yayooo

1.导出女装类目2020年整体销额，订单数，销量 2.导出2018年4月总销额大于2000元的商品，整年的订单数，销量，购买用户数，总金额 3.导出2019年订单单价在如下价...

yayooo

一、问题引入 问题引入：比较上面两张图，图1中，相同算子操作放在不同的slot中，图2中一个算子操作占用一个slot。如果flink window操作比较复杂，那么图2中就会...

yayooo

思考问题:1.怎么样实现并行计算？答：设置并行度。多线程，不同任务放到不同线程上。 2.并行的任务，需要占用多少slot？ 3.一个流处理程序，到底包含多少个任务？ 一、Ta...

yayooo

一、flink运行时架构图https://ci.apache.org/projects/flink/flink-docs-release-1.11/fig/processes...