耳邊的火

opentracing建議每個服務(wù)使用一個Tracer，Tracer構(gòu)建當(dāng)前服務(wù)中的span消请，兩個tracer見的通信，按照opentracing的規(guī)范类腮，貌似沒有理由讓tracer見保持通信臊泰。

jaeger代碼閱讀思路整理

jaeger實現(xiàn)了opentracing的規(guī)范，對Tracer與Span等接口寫了自己的實現(xiàn)蚜枢。根據(jù)opentracing的規(guī)范缸逃，每個服務(wù)建議只有一個Tracer，Tracer...

耳邊的火

7951 3 8

耳邊的火

Flink中的每個function與operator都可以是有狀態(tài)的需频。有狀態(tài)的function會在處理每個數(shù)據(jù)時存儲數(shù)據(jù)，使得狀態(tài)state成為需要更多精細(xì)操作的任意類型的o...

耳邊的火

上篇講了operator state在恢復(fù)（重啟/故障恢復(fù)）時要么使用evenly distributed策略修肠，要么使用union策略，來重啟operator的并發(fā)實例户盯。op...

耳邊的火

這篇文檔解釋了如何在開發(fā)應(yīng)用時嵌施，使用Flink的state饲化。 Keyed State and Operator State 在Flink有兩種基本的state：keyed s...

耳邊的火

OverviewWorking with StateThe Broadcast State PatternCheckpointingQueryable StateState ...

耳邊的火

有狀態(tài)的函數(shù)和操作符會在處理數(shù)據(jù)時存儲一些數(shù)據(jù)，這使得state成為了任何想要進行精細(xì)操作的操作符的關(guān)鍵組成部分吗伤。例如： 當(dāng)應(yīng)用尋找某些特定的模式的數(shù)據(jù)時吃靠，state可以存儲...

耳邊的火

Flink提供了接口，允許編程者自定義 timesatmp extractor 與 watermark emitter足淆。更確切的說巢块，可以根據(jù)情況，實現(xiàn) AssignerWit...

耳邊的火

這一部分文檔巧号，只和使用 event time語義的應(yīng)用有關(guān)族奢。為了使用 event time 語義，流程序需要設(shè)置相應(yīng)的 時間語義 time characteristic. 指...

耳邊的火

Event Time / Processing Time / Ingestion Time Flink 在流應(yīng)用中支持不同的時間概念： Processing Time: 處理...

耳邊的火

OverviewGenerating Timestamps / WatermarksPre-defined Timestamp Extractors / Watermark ...

耳邊的火

Flink中的流應(yīng)用就是在數(shù)據(jù)流上應(yīng)用各種轉(zhuǎn)化（如：filter,update state,difine window,aggregation）丹鸿。數(shù)據(jù)流有各種數(shù)據(jù)源創(chuàng)建而來（...

耳邊的火

Java 8 引入了一些為了提高編碼的速度與間接性的新特性越走。其中最重要的特性之一，便是“Lambda 表達(dá)式”靠欢，它打開了使用java進行函數(shù)是編程的大門廊敌。Lambda表達(dá)式允...

耳邊的火

Flink程序會在分布式的集合上進行各類轉(zhuǎn)化操作（如，filter,map,update state,join,group,window,aggregate）门怪。集合是由數(shù)據(jù)源...