weixin_45721882的博客

原创 flink sql 1.14 使用sql创建Kakfa动态表

需要的依赖<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.12</artifactId> <version>${flink.version}</version></dependency><dependency> <groupId>o

原创 求二分法平方根和Math.sqrt对比

不使用Math.sqrt()方法求平方根

原创 StructedStreaming显示完整的列内容

watermarkDF.writeStream .format("console") .outputMode("update") // TODO: 显示完整列内容 .option("truncate", "false") .start().awaitTermination().outputMode(“update”) // TODO: 显示完整列内容

原创 C++ 实现Get和Post请求（亲测）

废话不多说，直接上代码//#include <stdlib.h>#include "winsock2.h"#include <string>#include <iostream>using namespace std;#pragma comment(lib, "ws2_32.lib")#define IPSTR "127.0.0.1" //服务器IP地址;#define PORT 8080 //服务器端口;#define BUFSIZE 1024

原创 纯C语言进行Get和Post请求（亲测）

废话不多说，直接上代码#include <stdio.h>#include "winsock2.h"#include <string.h>#pragma comment(lib, "ws2_32.lib")#define IPSTR "127.0.0.1" //服务器IP地址;#define PORT 8080 //服务器端口;#define BUFSIZE 1024int getResponse(char *httpHeader,int getLength){

原创 高性能MySQL之第五章 创建高性能的索引

索引的类型B-Tree索引： InnoDB引擎使用B+Tree索引，NDB使用T-Tree结构索引; B+树索引可以分为 聚簇索引（也称聚集索引，clustered index）和辅助索引（有时也称非聚簇索引或二级索引，secondary index，non-clustered index）。 所有的值都是按顺序存储的 适合全键值、键值范围或键前缀查找。其中键前缀查找只适用于最左前缀的查找Hash索引：索引概念： 基于哈希表，将所有哈希码存储在索引中，同时

原创 Scala集合和Java集合互相转换

Scala的数组 转 Java的List方式一val arr = ArrayBuffer("1", "2", "3")val arrList = bufferAsJavaListConverter(arr).asJava //类型 Java.util.List方式二(过时)import scala.collection.JavaConverters.bufferAsJavaListval arrList = bufferAsJavaList(arr) // 类型 Java.util.Li

原创 HBase版本对应的Hadoop（应对版本不匹配问题）

网址http://hbase.apache.org/book.html#standalone_dist

原创 kafka群起脚本失败

脚本代码：#!/bin/bashcase $1 in"start"){ for i in hadoop01 hadoop02 hadoop03 do echo "-----------$i Kafka start------------------" ssh $i "/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/serv

原创 Zookeeper集群启动脚本

vim zkstart.shzkstart.sh#!/bin/bashif [ $# -lt 1 ]then echo "No Args Input..." exit ;fiif [ $1 = "start" -o "stop" -o "status" ]then #集群名 for i in hadoop01 hadoop02 hadoop03 do echo "-----------...

原创 beeline连接失败（xxx is not allowed to impersonate xxx）

WARN jdbc.HiveConnection: Failed to connect to hadoop01:10000Error: Could not open client transport with JDBC Uri: jdbc:hive2://hadoop01:10000: Failed to open new session: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException(org.apache.hadoop

原创 切片方法总结

四种切片方法TextInputFormatKeyValueTextInputFormatNLineInputFormatCombineFileInputFormatTextInputFormatTextInputFormat为默认的切片方法切片方式：  一次读取一行  一行数据按照分隔符进行切片KeyValueTextInputFormat切片方式：  按照分割符NLineInputFormat切片方式：  一次读取多行CombineFileInputFormat切片方式： 

原创 CombineTextInputFormat切片过程

CombineTextInputFormat 用于小文件过多的场景过程：首先将输入目录下所有文件大小，依次和设置的 setMaxInputSplitSize 值比较，如果小于设置的最大值，逻辑上划分一个块。如果大于设置的最大值且大于两倍，则以最大值切割一块；当剩余数据大小超过最大值且不大于最大值2倍，此时将文件均分成 2 个虚拟存储块（防止出现太小切片）测试举例：1、setMaxInputSplitSize 值为 4M有 4 个小文件大小分别为 1.7M、5.1M、3.4..

原创 简单的Linux文件权限说明

原创 CentOS 7安装 VMTools（安装VMware Tools显示灰色正确解决办法）

问题解决方法：在设置中选择CD/DVD使用ISO镜像文件，必须是VMware安装目录中的linux.iso，注意：表示自己下载的ISO文件设置以后开机，即可选择安装VM tools或重新安装VM tools

原创 keil5使用Arm Compiler 6编译出错

*** Using Compiler 'V6.15', folder: 'D:\Keil_v5\ARM\ARMCLANG\Bin'main.c(16): warning: In file included from...../USER/stm32f4xx.h(470): warning: In file included from...../CORE\core_cm4.h(170): warning: In file included from...../CORE\core_cmFunc.h(6..

原创 单片机使用12M晶振串口乱码问题

单片机使用12M晶振串口乱码问题，串口通信01或1，接收为81等等问题若是TH1和TL1=0xFD，将晶振改为11.0592MHZ重新下载或者按照以下步骤在STC-ISP中选择波特率计算器把波特率从9600改成了4800，并且勾上了波特率倍速，打开串口时，串口助手上波特率也修改为4800...

原创 Android使用讯飞出现空指针异常

（我只放了jar包）出现了ExceptionCaused by: java.lang.NullPointerException: Attempt to invoke virtual method 'boolean com.iflytek.cloud.SpeechRecognizer.setParameter(java.lang.String, java.lang.String)' on a null object reference把SDK的libs包(全部)拷贝到自己工程的libs目录下（这是我的

原创 Python进行PDF解密

PDF解密import pikepdf# opens a PDF with restrictive editing enabled, but that still# allows printing.def pdf_Crack(startFile,endFile): with pikepdf.open(startFile) as pdf: pdf.save(endFile) return endFile

原创 ensp简单ospf配置

拓扑图：1、R1配置 R2、R3、R4参考配置（1）配ip地址<Huawei>sys[Huawei]un in en[Huawei]sysn R1[R1]int s0/0/0[R1-Serial0/0/0]ip add 192.200.10.5 30[R1-Serial0/0/0]int e0/0/0[R1-Ethernet0/0/0]ip add 192.1.0.129 26[R1-Ethernet0/0/0]quit（2）配置ospf ：先设置区域 ，在

原创 The file name must end with .xml

找了一下午，思想局限了开始我将jar包放在的res文件中，一直找不到原因，在网上搜在[gradle.properties]添加android.disableResourceValidation=true表示失败。sync没有出现错误，都是build出现The file name must end with .xml最后 确定文件放错地方了 （应该放到libs文件中）在android Studio中加入 jar包方法1、将jar包放到libs文件夹下2、右击jar包选择ad..

原创 网络工程师实验配置

网络工程师实验配置ensp配置DHCP实验https://www.cnblogs.com/longshisan/p/12001196.html单臂路由实现VLAN间的划分https://www.cnblogs.com/arisskz6/p/11961998.html三层交换机实现VLAN间路由https://blog.csdn.net/qq_40163937/article/details/88886995将不断更新...

原创 网工五天修炼知识点总结

软考网工五天修炼总结可以明确软考的考点如有不足，请见谅！！！！

原创 python中将阿拉伯数字转换成中文的实现代码

新手测试在网上看有的代码有点多num=input()num1="0123456789"num2=['零','一','二','三','四','五','六','七','八','九']for i in num: for j in num1: if i==j: print(num2[int(j)],end="")