连击 天
fork: star:
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...
DataX在mysql间数据迁移操作 DataX概览 MysqlReader插件实现了从Mysql读取数据。在底层实现上,MysqlReader通过JDBC连接远程Mysql数据库,并执行相应的sql语句将数据从mysql库中SELECT出来。...
lockInterruptibly()方法能够中断等待获取锁的线程。当两个线程同时通过lock.lockInterruptibly()获取某个锁时,假若此时线程A获取到了锁,而线程B只有等待,那么对线程B调用threadB.interru...
分类算法----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...
没有更多内容
加载失败,请刷新页面
文章删除后无法恢复,确定删除此文章吗?
动弹删除后,数据将无法恢复
评论删除后,数据将无法恢复