flink业务使用记录 部署好flink集群，我的模式是flink on yarn 新建flink处理逻辑代码模块 将该模块打成可执行的jar放到整个项目中 在flink客户端执行提交作业操作 在flink管理页面上查看业务...

为了挑选并构造出对目标变量有较高预测力的自变量，需要对变量进行WOE编码，通过IV值的看变量的贡献。 1、WOE(weight of Evidence 证据权重) 1）解释及公式 WOE是对原始自变量的一种编码形式...

本文主要介绍了信用评分卡模型的概念，分析流程，使用场景，WOE,IV值等的详细介绍，还包括一个案例分析。 本文主要参考：https://www.jianshu.com/p/f931a4df202c https://blog.csdn.net/go...

ROC/AUC 作为机器学习的评估指标非常重要，也是面试中经常出现的问题（80% 都会问到）。其实，理解它并不是非常难，但是好多朋友都遇到了一个相同的问题，那就是：每次看书的时候都很明白，但...

https://my.oschina.net/u/3754001/blog/2995216 Azkaban实战案例:https://blog.csdn.net/qq_37334135/article/details/78359506......

BlockingQueue及其实现 1. 前言 BlockingQueue即阻塞队列，它是基于ReentrantLock，依据它的基本原理，我们可以实现Web中的长连接聊天功能，当然其最常用的还是用于实现生产者与消费者模式，...

LinkedList 源码分析 LinkedList 的概述 LinkedList 的构造方法 LinkedList 的增删改查。 LinkedList 作为队列（Queue）使用的时候增删改查。 LinkedList 的遍历方法 LinkedList 的概述 先来...

本文概述简介 FlinkCEP是在Flink之上实现的复杂事件处理（CEP）库。 它允许你在×××的事件流中检测事件模式，让你有机会掌握数据中重要的事项。 本文描述了Flink CEP中可用的API调用。 首先...

flink业务使用记录 部署好flink集群，我的模式是flink on yarn 新建flink处理逻辑代码模块 将该模块打成可执行的jar放到整个项目中 在flink客户端执行提交作业操作 在flink管理页面上查看业务...

Flink之Unio、coflatmap、CoGroup、Join以及Connect 问题导读 1.Flink 双数据流转换为单数据流操作有哪些？ 2.cogroup, join和coflatmap各自完成什么事情？ 3.cogroup, join和coflatmap区别是...

cv2.imdecode(np.fromfile(filename, dtype=np.uint8), cv2.IMREAD_COLOR) 讲解： np.fromfile() 读取图片，返回height,width,channels [cv2.imdecode](http://www.voidcn.com/article/p-sa...

钉钉数据相关文档 目的：主要实现统计员工的加班及考勤信息。 获取公司全员数据表【该表每天自动更新一次】 首先根据ACCESS_TOKEN获取部门列表；包括部门间的关系 然后根据ACCESS_TOKEN和dep...

DataX在mysql间数据迁移操作 DataX概览 MysqlReader插件实现了从Mysql读取数据。在底层实现上，MysqlReader通过JDBC连接远程Mysql数据库，并执行相应的sql语句将数据从mysql库中SELECT出来。...

lockInterruptibly()方法能够中断等待获取锁的线程。当两个线程同时通过lock.lockInterruptibly()获取某个锁时，假若此时线程A获取到了锁，而线程B只有等待，那么对线程B调用threadB.interru...

从上面报错可以看出，程序运行时候，没有找到“GLIBC_2.14”这个版本库，而默认的Centos6.9 glibc版本最高为2.12, 所以需要更新系统glibc库。 glibc是gnu发布的libc库，即c运行库，glibc是l...

分类算法----Logistic Regression算法 1. LR概述 1.1 概述 回归，就是对于一些无规律的点，利用线或者面将这些点进行拟合，这个过程就称之为回归。简单如下图所示： 其中红色的线就是将这些点...

opentsdb安装使用 注意：opentsdb 2.3.1及之后的版本才支持hbase 2.X版本，所以在安装之前查看下各自使用组件的版本 安装下载 opentsdb一般是从github下载tar.gz包 安装环境 centos7 jdk1.8...

需要分清三个概念： 物理CPU的个数 每个物理CPU的核数 物理CPU的核是否支持超线程 # 总核数 = 物理CPU个数 X 每颗物理CPU的核数 总逻辑CPU数 = 物理CPU个数 X 每颗物理CPU的核数 X 超线程数 ...

scala-opentsdb（仅作为个人学习记录使用） 目前工作需要使用flink接kafka数据写入opentsdb中，且使用的是scala。在网上找了好多都没有找到相关scala的jar包，但是幸运的是找到了java版的写o...

kafka-connect的standalone启动方式如下： ./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka-connect-snmp/quickstart-snmp.properties 在kafka源码中找到c...