1 相等判断 1.1 allEq 全部条件都相等。 1.2 eq 指定条件相等。 1.3 ne 指定条件不相等。 2 范围判断 2.1 gt 大于指定条件。 2.2 ge 大...
发简信
IP属地：上海
-
MyBatis-Plus 条件构造器常用方法使用（相等判断、范围判断、模糊匹配、非空判断、in判断、分组、排序、条件判断、逻辑判断、存在判断、查询字段）
-
flink是什么
架构 Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink设计为在所有常见的集群环境中运行，以内存速度和任何规模执行计算。在这...
-
Flink DataStream join小规模维度数据的简便方法
最近真的非常忙，所以只能写点这种类似工作总结的小短文了，看官勿怪。 在编写基于Flink的ETL程序时，我们经常需要用维度数据丰富我们接入的流式数据，如通过商品ID获得商品名...
-
JMM和底层实现原理1.并发编程领域的关键问题 1.1 线程之间的通信 线程的通信是指线程之间以何种机制来交换信息。在编程中，线程之间的通信机制有两种，共享内存和消息传递。在共享内存的并发模型里...
-
使用Jedis在高并发报错 (java.net.SocketException: Connection reset by peer: socket write error)
使用Jedis在高并发报错 (java.net.SocketException: Connection reset by peer: socket write error) ...
-
只有用心才能看得清实质性的东西，用眼睛是看不见的
-
EasyCode(代码神器)Easycode是IDEA的一个插件，可以直接对数据的表生成entity,controller,service,dao,mapper,无需任何编码，简单而强大。 1、安装(E...
-
Spark+Hbase 亿级流量分析实战（日志存储设计）接着上篇文章 Spark+Hbase 亿级流量分析实战（数据结构设计） 我们已经设计好了日志的结构，接下来我们就准备要开始撸代码了，我最喜欢这部分的环节了，可是一个上来连就撸...
-
我是大猪、一个让你沉迷于文章内容的IT写作者！
-
hadoop distcp hftp hdfs跨集群拷贝常见问题归总在工作中遇到部门间数据合作，需跨不同版本集群拷贝数据，从hadoop 2.6.0-cdh5.7.0 拷贝数据到hadoop 2.7.1， 记录所碰到的问题及解决方案。 dis...
-
Kafka扩容节点和分区迁移
背景 最近工作中碰到Kafka 节点的网卡成为了性能瓶颈，为了提高整个消息队列的输出吞吐量，需要将数据量大的Topic 迁移到新的Kafka节点上。 操作步骤 1. 新建Ka...
-
27 分析电子游戏在各国的销量并使用堆叠柱状图呈现分析电子游戏在各国的销量并使用堆叠柱状图呈现 数据集的样式 pandas 数据源下载地址 运行结果 图 总结 练习 使用堆叠柱状图比较不同来源的 PM2.5数值差异 题目描述...
-
Structured Streaming如何实现Parquet存储目录按时间分区
缘由 StreamingPro现在支持以SQL脚本的形式写Structured Streaming流式程序了： mlsql-stream。不过期间遇到个问题，我希望按天进行分...
-
flume传输大文件异常Input length = 2在使用flume spooling组件传输文件时，经常会出现以下问题： 1.文件只能传输一部分。 2.第二次将文件放到flume的监控目录下时，不能传输文件，监控目录中的文件...
-
flume与kafka集成遇到的问题与解决思路
0x00 背景知识 基本上想去用flume的同学都知道点flume的用途了。flume是一个分布式，可靠的，易用的，可以将不同源的日志进行，收集，汇总，或者存储的中间件。 0...
