flink - 專題 - 簡(jiǎn)書

投稿

flink

收錄了9篇文章 · 4人關(guān)注

Flink消費(fèi)Kafka如何保證相同標(biāo)識(shí)消息的有序性
1.需求在某些情況下违诗，我們需要保證flink在消費(fèi)kafka時(shí)睁枕，對(duì)于某些具有相同標(biāo)識(shí)的消息箱季，要保證其順序性。比如說具有相同uuid的用戶行為消...

0.3 LZhan 1 2
分布式Snapshot和Flink Checkpointing簡(jiǎn)介
摘要：最近在學(xué)習(xí)Flink的Fault Tolerance辖源，了解到Flink在Chandy Lamport Algorithm的基礎(chǔ)上擴(kuò)展實(shí)現(xiàn)了...

0.4 暖夏未眠丶 1 3

一文讓你徹底了解大數(shù)據(jù)實(shí)時(shí)計(jì)算引擎 Flink
前言在上一篇文章你公司到底需不需要引入實(shí)時(shí)計(jì)算引擎？中我講解了日常中常見的實(shí)時(shí)需求，然后分析了這些需求的實(shí)現(xiàn)方式诽偷，接著對(duì)比了實(shí)時(shí)計(jì)算和離線...

1.5 zhisheng_blog 1 8
Flink通信機(jī)制
flink內(nèi)部通信機(jī)制 Operator間的數(shù)據(jù)傳遞本地線程數(shù)據(jù)傳遞遠(yuǎn)程線程數(shù)據(jù)傳遞同一線程的Operator數(shù)據(jù)傳遞 Buffer讀寫B(tài)uff...

2.4 余楚倩 0 24
Flink 原理與實(shí)現(xiàn)：內(nèi)存管理
如今，大數(shù)據(jù)領(lǐng)域的開源框架（Hadoop疯坤，Spark报慕，Storm）都使用的 JVM，當(dāng)然也包括 Flink压怠∶吒裕基于 JVM 的數(shù)據(jù)分析引擎都需要面...

12.8 尼小摩 0 17
Apache Flink源碼解析（七）Flink RPC的底層實(shí)現(xiàn)
Prerequisites Flink的RPC服務(wù)是基于Akka Remote實(shí)現(xiàn)的。一個(gè)簡(jiǎn)單的Akka Remoting ActorSyste...

1.3 鐺鐺鐺clark 1 16
Flink 的Window 操作
Flink的 Window 操作 Window是無限數(shù)據(jù)流處理的核心菌瘫，Window將一個(gè)無限的stream拆分成有限大小的”buckets”桶蜗顽，...

3.5 寫B(tài)ug的張小天 4 54 1

Spring Boot 2 官方指導(dǎo)手冊(cè)譯文
入門介紹 Spring Boot Spring Boot 使您可以輕松地創(chuàng)建獨(dú)立的、生產(chǎn)級(jí)的基于 Spring 的應(yīng)用程序雨让，您可以運(yùn)行這些應(yīng)用...

1.7 Hsinwong 2 89 1
Apache Flink源碼解析（六）執(zhí)行計(jì)劃生成之StreamGraph-上半篇: 通過DataStream API
概述根據(jù)上一篇文章 DataStream API 可以得知每一個(gè)方法生成的Transformation和實(shí)際運(yùn)行中對(duì)Task的影響雇盖。事實(shí)上從T...

0.4 鐺鐺鐺clark 0 11 1