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