加载中
Azkaban Two Server模式部署

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

05/09 18:57
5
BlockingQueue及其实现

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

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

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

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

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

flink业务使用记录

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

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

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

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

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

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

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

DataX在mysql间数据迁移操作

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

03/23 14:29
528
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 概述 回归,就是对于一些无规律的点,利用线或者面将这些点进行拟合,这个过程就称之为回归。简单如下图所示: 其中红色的线就是将这些点...

03/16 19:07
101
opentsdb学习使用

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

03/16 19:07
181
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
233
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
229
prometheus远程存储

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

tensorflow与流计算结合使用:tf+java+flink

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

maven实用技巧篇

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

Flink

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

hbase使用记录

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

2019/06/04 10:27
106

没有更多内容

加载失败,请刷新页面

返回顶部
顶部