1 相等判斷 1.1 allEq 全部條件都相等。 1.2 eq 指定條件相等。 1.3 ne 指定條件不相等。 2 范圍判斷 2.1 gt 大于指定條件。 2.2 ge 大...
發(fā)簡(jiǎn)信
IP屬地：上海
-
MyBatis-Plus 條件構(gòu)造器常用方法使用（相等判斷、范圍判斷、模糊匹配、非空判斷、in判斷、分組、排序、條件判斷、邏輯判斷、存在判斷、查詢字段）
-
flink是什么
架構(gòu) Apache Flink是一個(gè)框架和分布式處理引擎，用于對(duì)無(wú)界和有界數(shù)據(jù)流進(jìn)行有狀態(tài)計(jì)算。Flink設(shè)計(jì)為在所有常見(jiàn)的集群環(huán)境中運(yùn)行，以內(nèi)存速度和任何規(guī)模執(zhí)行計(jì)算。在這...
-
Flink DataStream join小規(guī)模維度數(shù)據(jù)的簡(jiǎn)便方法
最近真的非常忙，所以只能寫點(diǎn)這種類似工作總結(jié)的小短文了，看官勿怪。 在編寫基于Flink的ETL程序時(shí)，我們經(jīng)常需要用維度數(shù)據(jù)豐富我們接入的流式數(shù)據(jù)，如通過(guò)商品ID獲得商品名...
-
JMM和底層實(shí)現(xiàn)原理1.并發(fā)編程領(lǐng)域的關(guān)鍵問(wèn)題 1.1 線程之間的通信 線程的通信是指線程之間以何種機(jī)制來(lái)交換信息。在編程中，線程之間的通信機(jī)制有兩種，共享內(nèi)存和消息傳遞。在共享內(nèi)存的并發(fā)模型里...
-
使用Jedis在高并發(fā)報(bào)錯(cuò) (java.net.SocketException: Connection reset by peer: socket write error)
使用Jedis在高并發(fā)報(bào)錯(cuò) (java.net.SocketException: Connection reset by peer: socket write error) ...
-
只有用心才能看得清實(shí)質(zhì)性的東西，用眼睛是看不見(jiàn)的
-
EasyCode(代碼神器)Easycode是IDEA的一個(gè)插件，可以直接對(duì)數(shù)據(jù)的表生成entity,controller,service,dao,mapper,無(wú)需任何編碼，簡(jiǎn)單而強(qiáng)大。 1、安裝(E...
-
Spark+Hbase 億級(jí)流量分析實(shí)戰(zhàn)（日志存儲(chǔ)設(shè)計(jì)）接著上篇文章 Spark+Hbase 億級(jí)流量分析實(shí)戰(zhàn)（數(shù)據(jù)結(jié)構(gòu)設(shè)計(jì)） 我們已經(jīng)設(shè)計(jì)好了日志的結(jié)構(gòu)，接下來(lái)我們就準(zhǔn)備要開(kāi)始擼代碼了，我最喜歡這部分的環(huán)節(jié)了，可是一個(gè)上來(lái)連就擼...
-
我是大豬、一個(gè)讓你沉迷于文章內(nèi)容的IT寫作者！
-
hadoop distcp hftp hdfs跨集群拷貝常見(jiàn)問(wèn)題歸總在工作中遇到部門間數(shù)據(jù)合作，需跨不同版本集群拷貝數(shù)據(jù)，從hadoop 2.6.0-cdh5.7.0 拷貝數(shù)據(jù)到hadoop 2.7.1， 記錄所碰到的問(wèn)題及解決方案。 dis...
-
Kafka擴(kuò)容節(jié)點(diǎn)和分區(qū)遷移
背景 最近工作中碰到Kafka 節(jié)點(diǎn)的網(wǎng)卡成為了性能瓶頸，為了提高整個(gè)消息隊(duì)列的輸出吞吐量，需要將數(shù)據(jù)量大的Topic 遷移到新的Kafka節(jié)點(diǎn)上。 操作步驟 1. 新建Ka...
-
27 分析電子游戲在各國(guó)的銷量并使用堆疊柱狀圖呈現(xiàn)分析電子游戲在各國(guó)的銷量并使用堆疊柱狀圖呈現(xiàn) 數(shù)據(jù)集的樣式 pandas 數(shù)據(jù)源下載地址 運(yùn)行結(jié)果 圖 總結(jié) 練習(xí) 使用堆疊柱狀圖比較不同來(lái)源的 PM2.5數(shù)值差異 題目描述...
-
Structured Streaming如何實(shí)現(xiàn)Parquet存儲(chǔ)目錄按時(shí)間分區(qū)
緣由 StreamingPro現(xiàn)在支持以SQL腳本的形式寫Structured Streaming流式程序了： mlsql-stream。不過(guò)期間遇到個(gè)問(wèn)題，我希望按天進(jìn)行分...
-
flume傳輸大文件異常Input length = 2在使用flume spooling組件傳輸文件時(shí)，經(jīng)常會(huì)出現(xiàn)以下問(wèn)題： 1.文件只能傳輸一部分。 2.第二次將文件放到flume的監(jiān)控目錄下時(shí)，不能傳輸文件，監(jiān)控目錄中的文件...
-
flume與kafka集成遇到的問(wèn)題與解決思路
0x00 背景知識(shí) 基本上想去用flume的同學(xué)都知道點(diǎn)flume的用途了。flume是一個(gè)分布式，可靠的，易用的，可以將不同源的日志進(jìn)行，收集，匯總，或者存儲(chǔ)的中間件。 0...
