LinkedBlockingQueue 是很优秀的阻塞队列实现，某些资料显示可以达到50w QPS左右，其读写使用两把锁，但底层使用ReentrantLock 进行阻塞，虽然...
发简信
IP属地：广西
-
利用分区概念增强阻塞队列吞吐量
-
Spring-KafkaListener使用
1.导包 2.Kafka配置类 3.配置文件（application.properties） 3.定义Consumer类 4.定义kafka-topic与实体类映射文件kaf...
-
ElasticSearch DSL 简单梳理
声明：本文为方便日后部分DSL结构速查，由于索引设计不同，语法会有差异,本文默认String 保存为keyword类型，详细了解移步Elastic Stack 官网 http...
-
-
重写fastjson序列化方法实现自定义key&value
一个特殊需求，需要数据库实体对象转换成json的时候，key为数据库原表字段，value Date 转String,找了找博客，看了看fastjson的源码之后,决定重写Ja...
-
Presto多协调者实现写在前面：Presto 是facebook开发的一款开源大数据OLAP引擎，基于内存计算和作业分发，直接使用sql分析，不需要数据预处理，类似于impala和sparksql...
-
Debezium、kafkaConnect、sqlserver数据同步
写在前面： 我先假设kafka已经安装好 1.opt 目录下创建一个文件夹 /opt/kafka-connect-pak 2.去confluent官网下载最新版conflue...
-
java 函数多返回值
思路一：利用数组 但这样指定不清晰，看上去也不怎么优雅 思路二：定义Pair对象 函数 取值： 看上去就舒服多了，举一反三，也可以定义Third 对象，里面有left ,mi...
-
zabbix 4.0安装
一：安装mysql1.查找是否有mysql安装 rpm -qa | grep -i mysqlrpm -qa | grep -i mariadb 2.安装依赖yum -y i...
-
zabbix监控kudu节点状态1.自定义kudu监控脚本cd /etc/zabbix/zabbix_agentd.dvim kudu_listen.sh cd /etc/zabbix/zabbix_age...
-
kudu增删改查（orm方式）
由于presto对kudu进行数据插入过慢，采用kudu-client之后写入可达每秒10w条，所以对kudu-client进行封装 kudu util工具类 自定义kudu...
-
直接用jdbc执行这个语句再取到create table语句的返回值就可以了，不过不建议用这份，不严谨，当时测试时写着玩的，还是建议直接读取mysql系统表，取到表和字段信息，然后转换成clickhouse表结构
mysql表结构转clickhouse 表结构
-
clickhouse集群搭建（1）ClickHouse是一个用于联机分析(OLAP)的列式数据库管理系统(DBMS)。可以用于PB级大数据实时分析，特点呢，就是快，比sparksql 和 impala还要快很...