Young_____Hu-CSDN博客

二叉树比当前节点小的在左边，大的在右边举例依次输入5、4、6、3、7、2、1则树长这样缺点：如果输入1、2、3、4、5、6、7则退化成链表平衡二叉树（红黑树）依次输入1、2、3、4、5、6、7结论不是完全平衡AVL树依次输入1、2、3、4、5、6、7得到如下图结论：完全平衡的二叉树、但是旋转次数太多了，如果查询远大于删除、修改可以如果删除和修改和查询差不多，则效果不如红黑树B Tree依次输入1、2、3、4、5、6、7、8、9、10、11、12、13、14、15、16

2021-12-16 15:37:21 872

原创 2021-09-15

springboot整合es1.pom版本需要与es版本一致，避免不必要的问题2.pom，在你的项目上加上以下依赖 <properties> <java.version>1.8</java.version> <elasticsearch.version>7.14.1</elasticsearch.version> </properties> <dependency>

2021-09-15 14:08:55 229

原创 db2级联查询

WITH RPL (ID,ParentID,NAME) AS(SELECT OPER_LABEL_TYPE as id ,LABEL_FATHER_TYPE as ParentID,LABEL_TYPE_NME as NAME FROM ncc_view.OPER_LABEL_TYPE WHERE OPER_LABEL_TYPE= ‘534050b6735e4a778884d873312af104’UNION ALLSELECT child.OPER_LABEL_TYPE as id,child.

2020-05-26 08:49:05 478

原创 springboot整合多数据源（mysql,impala）

springboot整合多数据源，这里以mysql和impala举例子1.pom.xml <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId></dependency><dependency> <groupId>com.cloudera</groupId>

2020-05-16 20:13:55 1753

原创 mysql优化

索引单表索引小于等于5个，太多的索引反而增加查询时间单表索引失效索引上做函数，等任何处理容易索引失效不等于（!=或者<>）容易索引失效is not null索引失效，is null索引有效like ‘%abc’ 索引失效 like ‘abc%’ 索引有效字符串不加单引号索引失效where 查询时，有索引的字段放前面关联查询join 字段有索引le...

2020-04-06 18:16:34 141

原创 SparkStreaming的两种wordCount

object HelloWord01 { def main(args: Array[String]): Unit = { //基本配置 val conf = new SparkConf().setMaster("local[*]").setAppName("HelloWord01") val ssc = new StreamingContext(conf, Secon...

2020-03-28 16:14:24 204

原创 Spark-udf自定义函数（强类型）

object learn04 { def main(args: Array[String]): Unit = { //基本配置 val conf = new SparkConf().setAppName("learn01").setMaster("local[*]") val spark = SparkSession.builder().config(conf).ge...

2020-03-28 11:34:11 409 1

原创 Spark自定义累加器

object leijiaqi { def main(args: Array[String]): Unit = { //基本配置 val conf = new SparkConf().setAppName("myRddLearn").setMaster("local[*]") val spark = SparkSession.builder().config(con...

2020-03-26 19:54:13 360

原创 JSR303加全局异常处理器

JSR303需要的依赖  <dependency> <groupId>javax.el</groupId> <artifactId>javax.el-api</artifactId> <versi...

2020-03-24 11:44:34 293

原创 RDD-KV

这里简单描述一下几个rdd，key-values的使用groupByKeyreduceByKeyaggregateByKeyfoldByKeycombineByKeymapValuesjoingroupByKey返回((key,value数组),(key,value数组))//定义两个kv类型的rddval rdd1: RDD[(Int, String)] = spark...

2020-03-23 15:07:29 301

原创并发编程几个常用工具

synchronized很多人看到这个就认为这个是重量锁由于每个类创建的对象JVM默认是偏向锁，在不发生线程争加锁资源的时候只是偏向锁这个类的偏向锁t1在被撤销的时候，变成了轻量锁当撤销次数为20次的时候，后面的开始又变成了偏向锁t2当撤销次数达到40次的时候，这个类所有偏向锁都变成轻量锁中间如果发送线程争夺资源，直接是重量锁//设置次数40次 int time ...

2020-03-19 21:53:40 161

原创自定义注解aop

首先要有一个注解@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME) public @interface MyLog {}然后有一个切面类@Component@Aspectpublic class MyLogAspect { @Pointcut("@annotation(cn.alibaba.My...

2019-11-07 17:19:33 222

原创 kafka windows启动

1.开启自带的zookeeperbin\windows\zookeeper-server-start.bat config\zookeeper.properties2.启动kafka服务端bin\windows\kafka-server-start.bat config\server.properties3.查看有哪些topicbin\windows\kafka-topics.bat...

2019-10-12 15:37:06 598

原创 websocket应用

pom<dependency> <groupId>javax.websocket</groupId> <artifactId>javax.websocket-api</artifactId> <version>1.0</version> ...

2019-07-23 16:38:38 230

原创 Spark得checkPoint和Cache

Cache举例子：rdd2依赖rdd1rdd3依赖rdd2rdd3.cache()//会把rdd3存入内存中，以后可以非常快得直接从内存中取问题1：如果rdd3.cache()存入得数据是50G而我们实际内存可能只有32G 他会只存一部分，下次你再用rdd3得时候 50G其中32G会直接从内存中取，剩下得18G从新计算得出，依旧会比50G计算快得多。这里只是举个例子。阅读源码...

2019-06-05 21:52:24 209

原创子页面监听父页面事件

父页面a.html<select id="a" onchange="aaa()"><option>1</option><option>2</option><option>3</option></select>通过jquery改变$('#a).val(3)//3被选中，可是不会触发chan...

2019-06-05 19:12:49 1652

原创 java.lang.nosuchmethoderror:java.lang.character.isSurrogate(C)Z

问题描述:写了一个走http请求得接口，json格式当postman发送得aaa是数字或者字母得时候没有问题，aaa是中文时候进不去方法报错405，报上面标题错误public void demo(@ResponeBody String aaa){}解决方法：看看你有没有用fastjson，我的是fastjson和jdk版本不匹配，jdk版本太低，所以把jdk换成1.8就行了...

2019-05-27 15:35:50 514

原创选择排序

Integer[] array = {1, 13, 35, 27, 9, 111, 13};第一次：比较1和其他得最小得和1交换最后结果{1, 13, 35, 27, 9, 111, 13}第二次：比较13和其他得最小得和13交换最后结果{1, 9, 35, 27, 13, 111, 13}第三次：比较35和其他的最小得和35交换最后结果{1, 9, 13, 27, 35...

2019-05-16 11:27:25 111

原创二分查找

二分查找得前提，这个数组必须被排好序，否则无意义。 public static void main(String[] args) { Integer[] array = {1, 3, 5, 7, 9, 11, 13}; Integer result = sortBy(array, 9); System.out.println(result+1);...

2019-05-16 10:48:33 119

原创 windows安装hadoop2.8.4

由于winutils不好下载，很多csdn都是要积分才能下载，我很不喜欢这点。所以我决定把我的放到网盘大家都可以下载这两个需要下载的都在这个公开的文件夹下面链接：https://pan.baidu.com/s/10sPedrHvb0dMWsbyjk1Qqg提取码：xslh复制这段内容后打开百度网盘手机App，操作更方便哦1.下载hadoop2.8.42.配置环境变量3.下载winut...

2019-05-05 23:04:04 1184

原创 Rdd算子之reduce

/**分三个分区：* 分区1：1、2* 分区2：3、4* 分区3：5、6、7*每个分区内部进行相加*（1+2）+（3+4）+（（5+6）+7）**/private static void reduce() { SparkConf conf = new SparkConf().setAppName("hzy").setMaster("local"); ...

2019-05-05 22:45:56 987

原创 Rdd算子之aggregate

aggregate是聚合的意思private static void arrgue1() { SparkConf conf = new SparkConf().setAppName("hzy").setMaster("local"); JavaSparkContext sparkContext = new JavaSparkContext(conf); ...

2019-05-05 22:41:21 215

原创 Spark的wordcount

private static void wordCount() { //设置这次任务的名字和设置本地跑spark程序 SparkConf conf = new SparkConf().setAppName("hzy").setMaster("local"); JavaSparkContext sparkContext = new JavaSparkC...

2019-05-05 22:36:35 81

原创 Nginx服务器反向代理

好久没有用nginx服务器了，这次公司又用到了，就写写一般公司用nginx的反向代理把。业务场景：由于我们是手机端只能访问一个ip，通过那个ip上部署的nginx来访问内网的项目，就需要在nginx上配置反向代理了。##这里可以配置多个端口号，比如我们5000,5001,5002,5003分别是测试端口，正式端口等等server{ listen 5001; server_n...

2019-04-23 16:04:30 178

原创 DB2数据库报错

报错SQLCODE=-407, SQLSTATE=23502, SQLERRMC=TBSPACEID=5, TABLEID=30, COLNO=0, DRIVER=3.50.152解决方法根据报错信息，把实例名，表名，colno填入就可知道哪个字段出错select * from syscat.columns where tabschema = 'DB2INST1' and TABNAME...

2019-03-19 17:40:51 680

原创 flume数据采集到kafka

agent.sources = s1agent.channels = c1agent.sinks = k1agent.sources.s1.type=execagent.sources.s1.command=tail -F /usr/local/flume/testflume2/hzytest.logagent.sources.s1.channels=c1agent.channels...

2019-02-27 10:05:01 1831

原创 flume文件采集

flume的两种采集模式1.以文件为答案，只要新增了一个文件就把该文件采集到hdfs上去配置文件如下#定义三大组件的名称agent1.sources = source1agent1.sinks = sink1agent1.channels = channel1# 配置source组件agent1.sources.source1.type = spooldir#从这个文件夹下采集...

2019-01-15 15:55:43 1816

原创 org\pentaho\pentaho-aggdesigner-algorithm\5.1.5-jhyde.jar找不到

写hive的自定义函数时遇到的问题导入maven的jar包发现pom报错两个jar没有<dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-exec</artifactId> <version>1.1.1</version>&a

2019-01-11 10:36:04 5110 3

原创 MapReducer-wordCount

public class WordCountMapper extends Mapper<LongWritable, Text, Text, IntWritable>{ @Override protected void map(LongWritable key, Text value, Context context) throws IOException, Interrup...

2018-12-19 23:12:09 148

原创 Hadoop-代码的几种跑法

1.Hadoop可以安装在linux上，一般以集群安装。也可安装在windows上，开发人员可以在本地安装一个hadoop这样在开发阶段可以直接跑本地模式，方便debug2.IDEA上或者eclipse上可以跑mapreducer代码。有三种方式直接在本地跑。直接在集群上跑在本地跑集群这里简单说两种本地跑和集群上跑集群上跑需要把项目打成jar包集群启动namenode、datan...

2018-12-19 22:57:18 460

原创去掉对象里面的换行符

使用了反射和递归/** * 去掉对象的换行符 * * @param object * @throws IllegalArgumentException * @throws IllegalAccessException */ public static void removeObjectRN(Object object) throws IllegalArgumentEx...

2018-11-30 15:02:48 528

原创 java.io.IOException: 你的主机中的软件中止了一个已建立的连接

java.io.IOException: 你的主机中的软件中止了一个已建立的连接。 at sun.nio.ch.SocketDispatcher.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43) at sun.nio.ch.IOUtil.readIntoNativeBuffer...

2018-11-27 21:03:55 10986 4

原创 netty整合spring

首先注意一个大坑，你的netty的jar是4.xxx不，如果是请注意一定要这个注解import io.netty.channel.ChannelHandler.Sharable;@Sharable这个注解的功能是，有了它才能连接多个handler否则只能连接一个handler，我被这个坑了快一个星期了，每次都是第一次连接好的，第二次连接就报错java.io.IOException: 你的主...

2018-11-27 20:55:05 1249

原创 shell

分享一波用shell写的脚本语言，从数据库导文件并且按照一定格式由于银行要求格式是:字段A|字段B 然后是gbk编码的，我们数据库是utf8 ，文件名以.uml结尾#!/bin/bashtest(){//创建文件夹把五张表都放进去mkdir customerExport db2 connect to sunpls user db2icomm using db2icommdb...

2018-11-27 16:59:07 117

原创 nio与netty

IO分为三种BIO(传统IO) 同步阻塞IONIO同步非阻塞IOAIO异步非阻塞IO（涉及linux网络底层，太难，这里不讨论）阻塞和非阻塞区别：传统IO是阻塞的，因为read(),write()方法就是阻塞的，此时必须等读完了或者写完了才能进行后面的操作。NIO是非阻塞的，才用多路复用技术，把read()和write()单独给了一个线程，由操作系统完成，所以操作系统读完了或者写完了...

2018-11-22 09:54:33 146

原创多线程锁

多线程锁主要有synchronized和lock区别：synchronized粒度大，释放锁只有两种情况，1，被锁住的代码执行完毕，2抛异常JVM会主动开锁。lock粒度小，开锁和解锁都必须由我们自己的代码实现lock是接口，常用实现类有ReentrantLock、ReentrantReadWriteLock实现ReentrantLocklock()—获取锁unlock()—释放...

2018-11-20 23:23:37 126

原创多线程

实现多线程有三个方法继承Thread和实现Runable，CallableThread不建议使用：一个类只能有一个父类，能用接口就不要用继承因为我们一般用线程池不是直接new Thread()Runable：没有返回值，多开了一个线程跑到多少步了不知道Callable有返回值，可以知道跑到哪一步，不想知道也可以不知道只拿Runable和Callable举例子publi...

2018-11-20 21:39:54 131

原创反射

反射反射用途：银行基本上都是用xml报文格式来传输的，所以我们需要用到bean转xml和xml转bean，因为对一个平台，报文头一样，报文体根据bean的成员变量不一样而不一样所以可以写一个公共的方法让bean转xml，这样其他人传进来一个对象就可以直接变成请求xml这里没有写如何转xml，需要知道如何转xml可以用dom4j自行了解。这里主要写反射的基本，结合反射和dom4j就可以做到写一...

2018-11-20 21:15:50 117

原创 Socket的基本使用

socket是什么套接字，可以用作传输之一，有TCP协议和UDP协议，其他自己百度。。。服务端服务端一般采用多线程方式public class SocketThread implements Runnable { private Socket socket; public SocketThread(Socket socket) { this.socket = socket; ...

2018-11-15 15:27:26 250

database.zip

空空如也