All Projects → mickey0524 → flink-streaming-source-analysis

mickey0524 / flink-streaming-source-analysis

Licence: other
flink 流处理源码分析

Programming Languages

java
68154 projects - #9 most used programming language
scala
5932 projects

Projects that are alternatives of or similar to flink-streaming-source-analysis

apache-flink-jdbc-streaming
Sample project for Apache Flink with Streaming Engine and JDBC Sink
Stars: ✭ 22 (-53.19%)
Mutual labels:  flink, flink-stream-processing
cassandra.realtime
Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
Stars: ✭ 25 (-46.81%)
Mutual labels:  flink, flink-stream-processing
Lidea
大型分布式系统实时监控平台
Stars: ✭ 28 (-40.43%)
Mutual labels:  flink
open-stream-processing-benchmark
This repository contains the code base for the Open Stream Processing Benchmark.
Stars: ✭ 37 (-21.28%)
Mutual labels:  flink
TiBigData
TiDB connectors for Flink/Hive/Presto
Stars: ✭ 192 (+308.51%)
Mutual labels:  flink
flink-spark-submiter
从本地IDEA提交Flink/Spark任务到Yarn/k8s集群
Stars: ✭ 157 (+234.04%)
Mutual labels:  flink
SANSA-Stack
Big Data RDF Processing and Analytics Stack built on Apache Spark and Apache Jena http://sansa-stack.github.io/SANSA-Stack/
Stars: ✭ 130 (+176.6%)
Mutual labels:  flink
Flink Boot
懒松鼠Flink-Boot 脚手架让Flink全面拥抱Spring生态体系,使得开发者可以以Java WEB开发模式开发出分布式运行的流处理程序,懒松鼠让跨界变得更加简单。懒松鼠旨在让开发者以更底上手成本(不需要理解分布式计算的理论知识和Flink框架的细节)便可以快速编写业务代码实现。为了进一步提升开发者使用懒松鼠脚手架开发大型项目的敏捷的度,该脚手架默认集成Spring框架进行Bean管理,同时将微服务以及WEB开发领域中经常用到的框架集成进来,进一步提升开发速度。比如集成Mybatis ORM框架,Hibernate Validator校验框架,Spring Retry重试框架等,具体见下面的脚手架特性。
Stars: ✭ 209 (+344.68%)
Mutual labels:  flink
Websockets-Vertx-Flink-Kafka
A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.
Stars: ✭ 14 (-70.21%)
Mutual labels:  flink
dpkb
大数据相关内容汇总,包括分布式存储引擎、分布式计算引擎、数仓建设等。关键词:Hadoop、HBase、ES、Kudu、Hive、Presto、Spark、Flink、Kylin、ClickHouse
Stars: ✭ 123 (+161.7%)
Mutual labels:  flink
logparser
Easy parsing of Apache HTTPD and NGINX access logs with Java, Hadoop, Hive, Pig, Flink, Beam, Storm, Drill, ...
Stars: ✭ 139 (+195.74%)
Mutual labels:  flink
parquet-flinktacular
How to use Parquet in Flink
Stars: ✭ 29 (-38.3%)
Mutual labels:  flink
FlinkExperiments
Experiments with Apache Flink.
Stars: ✭ 3 (-93.62%)
Mutual labels:  flink
flink-connector-kudu
基于Apache-bahir-kudu-connector的flink-connector-kudu,支持Flink1.11.x DynamicTableSource/Sink,支持Range分区等
Stars: ✭ 40 (-14.89%)
Mutual labels:  flink
fdp-modelserver
An umbrella project for multiple implementations of model serving
Stars: ✭ 47 (+0%)
Mutual labels:  flink
seatunnel-example
seatunnel plugin developing examples.
Stars: ✭ 27 (-42.55%)
Mutual labels:  flink
Flink Doc Zh
Apache Flink 中文文档
Stars: ✭ 242 (+414.89%)
Mutual labels:  flink
bigdata-doc
大数据学习笔记,学习路线,技术案例整理。
Stars: ✭ 37 (-21.28%)
Mutual labels:  flink
dockerfiles
Multi docker container images for main Big Data Tools. (Hadoop, Spark, Kafka, HBase, Cassandra, Zookeeper, Zeppelin, Drill, Flink, Hive, Hue, Mesos, ... )
Stars: ✭ 29 (-38.3%)
Mutual labels:  flink
flink-deployer
A tool that help automate deployment to an Apache Flink cluster
Stars: ✭ 143 (+204.26%)
Mutual labels:  flink

flink 流处理源码分析

目前社区内没有对 flink 流处理源码解析的文章,本 repo 的目标是全方位细致解析 flink 流处理的实现原理,加深大家对 flink 流式处理的认识

本 repo 分析的 flink 版本为 1.7.2,预计将会从几篇系列文章或方面来展开:

另外,在 flink-java-streaming-src 目录中有我对 flink 流式处理逐行代码的详细分析,大家有兴趣的可以看看

如果大家觉得本 repo 对您有所帮助,可以点个 star

比较好的 flink 资料

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].