加载中
flink业务使用记录

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

2020/12/25 23:06
48
逻辑回归中常用的概念: WOE、IV详解

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

2020/08/20 12:13
408
信用评分卡模型总结

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

一文让你彻底理解准确率,精准率,召回率,真正率,假正率,ROC/AUC

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

2020/08/20 11:47
675
Azkaban Two Server模式部署

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

2020/05/09 18:57
35
BlockingQueue及其实现

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

2020/04/18 15:33
137
LinkedList/ArrayList 源码分析

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

2020/04/16 20:21
82
Flink进阶-Flink CEP(复杂事件处理)

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

flink业务使用记录

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

2020/03/31 21:44
344
Flink之Unio、coflatmap、CoGroup、Join以及Connect

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

2020/03/31 18:40
321
车牌识别学习记录

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...

2020/03/28 13:26
70
钉钉数据相关文档

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

2020/03/23 17:30
69
DataX在mysql间数据迁移操作

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

2020/03/23 14:29
2.8K
Lock的lockInterruptibly()方法

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

2020/03/20 17:21
176
Centos6.5安装net-snmp时“libc.so.6: version GLIBC_2.14 not found”问题

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

分类算法----Logistic Regression算法

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

2020/03/16 19:07
157
opentsdb学习使用

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

2020/03/16 19:07
489
Linux查看物理CPU个数、核数、逻辑CPU个数

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

2019/12/03 18:02
42
scala写opentsdb

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

2019/08/15 23:20
348
kafka-connect之standalone启动流程源码梳理

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

2019/08/07 11:51
700

没有更多内容

加载失败,请刷新页面

返回顶部
顶部