课程三数字的基础知识python控制台可以执行的当做计算器去执行算数比如在python控制台执行执行[root@flink-slave5~]#ipythonPython3.7.4(default,Aug132019,20:35:49)Type‘copyright‘,‘credits‘or‘license‘formoreinformationIPython7.8.0--AnenhancedInter
分类：
编程语言 时间：
2020-01-01 10:16:21
阅读次数：
76
前言... Java最早是由SUN公司（已被Oracle收购）的詹姆斯·高斯林（高司令，人称Java之父）在上个世纪90年代初开发的一种编程语言，最初被命名为Oak，目标是针对小型家电设备的嵌入式应用，结果市场没啥反响。谁料到互联网的崛起，让Oak重新焕发了生机，于是SUN公司改造了Oak，在199 ...
分类：
编程语言 时间：
2019-12-30 21:38:36
阅读次数：
92
基础概念 FlinkCEP 说明 一个或多个由简单事件构成的事件流通过一定的规则匹配，然后输出用户想得到的数据，满足规则的复杂事件。具备如下的特征： 目标：从有序的简单事件流中发现一些高阶特征 输入：一个或多个由简单事件构成的事件流 处理：识别简单事件之间的内在联系，多个符合一定规则的简单事件构成复 ...
分类：
其他好文 时间：
2019-12-30 10:00:03
阅读次数：
130
如何提高 Flink 任务性能 一、Operator Chain 为了更高效地分布式执行，Flink 会尽可能地将 operator 的 subtask 链接（chain）在一起形成 task，每个 task 在一个线程中执行。将 operators 链接成 task 是非常有效的优化：它能减少线程 ...
分类：
其他好文 时间：
2019-12-29 14:44:39
阅读次数：
244
典型的风控场景包括：注册风控、登陆风控、交易风控、活动风控等，而风控的最佳效果是防患于未然，所以事前事中和事后三种实现方案中，又以事前预警和事中控制最好。 系统架构 业务系统 风控系统，为业务系统提供支持，根据业务系统传来的数据或埋点信息来判断当前用户或事件有无风险； 惩罚系统，业务系统根据风控系统 ...
分类：
其他好文 时间：
2019-12-26 21:45:02
阅读次数：
207
一手资料，完全来自官网，直接参考英文过来的，并加了一些自己的理解，希望能让看官君了解点什么，足矣。 环境：Flink1.9.1 难度：新手--战士--老兵--大师 目标： 理解Flink的计算模型 认识各重要组件 说明： 本篇作为前两篇的补充内容，算是理论篇 步骤： 01-Flink编程模型 Fli ...
分类：
其他好文 时间：
2019-12-26 13:17:20
阅读次数：
96
因为想用以下flink的ml功能，因此需要将flink升级到1.9.修改pom文件版本后，代码几乎没报错，一阵高兴，只有批处理的创建变了BatchTableEnvironmenttableEnv=newBatchTableEnvironment(env,TableConfig.DEFAULT());变为BatchTableEnvironmenttableEnv=BatchTableEnvironm
分类：
其他好文 时间：
2019-12-25 22:22:40
阅读次数：
492
一：WaterMark 本质：时间戳 作用：用于处理乱序事件 适用场景：基于事件时间做窗口运算 产生频率：默认是来一条数据下发一次watermark，但是可以调整setAutoWatermarkInterval参数设置下发watermark的时间间隔，性能会有一定的提升。 多并发的情况下，取wate ...
这里将介绍Flink对有状态计算的支持，其中包括状态计算和无状态计算的区别，以及在Flink中支持的不同状态类型，分别有 Keyed State 和 Operator State 。另外针对状态数据的持久化，以及整个 Flink 任务的数据一致性保证，Flink 提供了 Checkpoint 机制处 ...
分类：
其他好文 时间：
2019-12-24 18:32:48
阅读次数：
94
使用flink FlinkKafkaProducer 往kafka写入数据的时候要求使用EXACTLY_ONCE语义 本以为本以为按照官网写一个就完事，但是却报错了 代码 遇到问题 当 指定为 时，执行没有问题。 当 指定为 时，执行报下面的错误： 错误大意是： 事务超时大于broker允许的最大值 ...
分类：
其他好文 时间：
2019-12-24 18:23:29
阅读次数：
962
