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出来。...

从上面报错可以看出，程序运行时候，没有找到“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...

该文章包含prometheus写kafka/influxdb/opentsdb三部分； 由于刚接触go语言，有不正确的地方请不吝赐教。 prometheus远程存储-kafka 实验系统配置 mac 10.14 docker Engine: Version: 18.09....

tensorflow与java结合 【导读】 随着TensorFlow的普及，越来越多的行业希望将Github中大量已有的TensorFlow代码和模型集成到自己的业务系统中，如何在常见的编程语言（Java、NodeJS等）中使用...

maven实用技巧篇 多线程及跳过测试 # 用 4 个线程构建，以及根据 CPU 核数每个核分配 1 个线程进行构建 $ mvn -T 4 clean install $ mvn -T 1C clean install -DskipTests # 不执行测试用例，...

flink HA部署 flink搭建，采用分布式部署方式，分别为A,B,C三个节点。其中A为master;A,B,C为worker。 本文使用的用户是hadoop用户（自己新建） 先决条件 Java 1.8.x or higher scala 自己使用...

hbase数据存储格式 HBase是一个分布式的、面向列的开源数据库,源于google的一篇论文《bigtable：一个结构化数据的分布式存储系统》。HBase是Google Bigtable的开源实现，它利用Hadoop HDFS作...