上一篇文章粗略介紹了一下matplotlib的基本概念，見matplotlib 初步介紹 之所以寫這篇，是記錄一下自己對matplotlib中的event的event交互的學(xué)...
IP屬地：貴州
-
matplotlib 介紹之event 交互
-
hive分區(qū)表
hive分區(qū)表 1 為什么出現(xiàn)分區(qū)表？ 假設(shè)有海量的數(shù)據(jù)保存在hdfs的某一個hive表明對應(yīng)的目錄下，使用hive進(jìn)行操作的時候，往往會搜索這個目錄下的所有文件，這有時會非...
-
WeTest網(wǎng)站壓力測試使用最近對網(wǎng)站進(jìn)行壓力測試，然后搜到了WeTest這個平臺，然后個人認(rèn)證還有免費(fèi)的VUM贈送（對于我來說夠用了） 但是在使用的過程中，發(fā)現(xiàn)網(wǎng)上還沒有多少教程，過程中自己也遇到了很...
-
matplotlib 介紹之event 交互
上一篇文章粗略介紹了一下matplotlib的基本概念，見matplotlib 初步介紹 之所以寫這篇，是記錄一下自己對matplotlib中的event的event交互的學(xué)...
-
WeTest網(wǎng)站壓力測試使用
最近對網(wǎng)站進(jìn)行壓力測試，然后搜到了WeTest這個平臺，然后個人認(rèn)證還有免費(fèi)的VUM贈送（對于我來說夠用了） 但是在使用的過程中，發(fā)現(xiàn)網(wǎng)上還沒有多少教程，過程中自己也遇到了很...
-
Flink端到端一致性調(diào)研目錄 一、一致性定義 Flink通過插入barrier將流分為邏輯上的批，用來保存狀態(tài)。因此一個checkpointid可以理解為一批數(shù)據(jù)的狀態(tài)改變。當(dāng)checkpoint ...
-
KafkaProducer011
For each checkpoint we create new FlinkKafkaProducer so that new transactions will not ...
-
Flink Local state VS External StateState Backend Support local state Local state backends maintain all state in local memo...
-
jdk8特性-CompletableFuture
CompletionStage接口翻譯成中文是“完工階段“，是java8新增的一個工具。定義的一系列方法，接收的參數(shù)有有三類CompletionStage，Runnable，...
-
mongo索引（特別是文本索引）
前言 首先，我想說的是，看官方文檔很重要，雖然可能都是英文，并且也很長，但是基本都很有用。 普通索引 不多介紹，一搜一大把，簡要介紹可以看菜鳥教程 文本索引 之前在進(jìn)行文本匹...
-
Apache Flink源碼解析 （七）Flink RPC的底層實現(xiàn)
Prerequisites Flink的RPC服務(wù)是基于Akka Remote實現(xiàn)的。一個簡單的Akka Remoting ActorSystem的配置如下:akka { ...
-
通信機(jī)制 Storm vs. FlinkStorm通信機(jī)制 Storm和Flink都是流計算系統(tǒng)中比較成熟的開源實現(xiàn)，在一些流計算平臺選型的文章中，兩者也常常被拿來重點比較,但是兩個平臺都在持續(xù)更新，一些選型比較和...
-
Flink通信機(jī)制flink內(nèi)部通信機(jī)制 Operator間的數(shù)據(jù)傳遞本地線程數(shù)據(jù)傳遞遠(yuǎn)程線程數(shù)據(jù)傳遞同一線程的Operator數(shù)據(jù)傳遞 Buffer讀寫B(tài)uffer讀取Buffer寫入 內(nèi)存...
-
確定性流處理總結(jié)StreamScope和flamestream實現(xiàn)了確定性流處理。 1.實現(xiàn)思想 這兩篇論文中都指出需要實現(xiàn)確定性的處理，需要保證 確定的執(zhí)行邏輯，即相同的輸入會有相同的輸出...
-
Flamestream簡單介紹1. 核心思想 通過把狀態(tài)變成流的一部分，引入循環(huán)圖，使得上一個item的狀態(tài)可以作為下一個item的輸入，使得有狀態(tài)算子變成無狀態(tài)算子。 be input and outp...
-
