《老炮兒》里有不少北京的特色吃食。 煎餅果子 煎餅果子是北京街頭常見的平民食品策橘。戲里開場谎倔，燈罩兒就是因?yàn)榧屣灁倹]辦證被城管抄了心赶。 《老炮兒》里現(xiàn)成有買煎餅果子的一幕戲，很地道...
發(fā)簡信
IP屬地：浙江
-
吃得起的肚仁瑟幕，買不起的平房丨《老炮兒》里的北京 -
flink學(xué)習(xí)之八-keyby&reduce
上文學(xué)習(xí)了簡單的map、flatmap焕盟、filter，在這里開始繼續(xù)看keyBy及reduce keyBy 先看定義宏粤，通過keyBy脚翘，DataStream→KeyedStre...
-
rabbitmq可靠確認(rèn)模式的java封裝及示例最近的一個計費(fèi)項(xiàng)目，在rpc調(diào)用和流式處理之間徘徊了許久绍哎，后來選擇流式處理来农。一是可以增加吞吐量，二是事務(wù)的控制相比于rpc要容易很多崇堰。 確定了流式處理的方式沃于，后續(xù)是技術(shù)的選型...
-
flume1.8存儲到hdfs上缺少的jar包
821 cp /data/software/hadoop-3.0.0/share/hadoop/common/hadoop-common-3.0.0.jar ./lib/8...
-
（基于最新的Kafka version 0.10.2 new consumer API ）想要Spark Streaming精確一次消費(fèi)Topic涩咖？拿去不謝，記得點(diǎn)贊和分享繁莹！本文基于Spark2.1.0檩互、Kafka 0.10.2、Scala 2.11.8版本 背景： Kafka做為一款流行的分布式發(fā)布訂閱消息系統(tǒng)蒋困，以高吞吐盾似、低延時、高可靠的特點(diǎn)著...
-
如何實(shí)現(xiàn)一個簡單的RPC在如何給老婆解釋什么是RPC中雪标，我們討論了RPC的實(shí)現(xiàn)思路零院。那么這一次，就讓我們通過代碼來實(shí)現(xiàn)一個簡單的RPC吧村刨！ RPC的實(shí)現(xiàn)原理 正如上一講所說告抄，RPC主要是為了解決的兩...
-
Spark Job 詳細(xì)執(zhí)行流程（二）
Spark Job執(zhí)行流程大體如下：用戶提交Job后會生成SparkContext對象，SparkContext向Cluster Manager（在Standalone模式下...
-
Spark executor中task的數(shù)量與最大并發(fā)數(shù)
關(guān)于executor和task的概念可以參考官方文檔本文使用的源碼是spark 2.0.0版本 Task的數(shù)量 根據(jù)類DAGScheduler中的submitMissingT...
