11 Star 54 Fork 16

Sisyphus / flink-batch-stream

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
Flink核心特性.md 807 Bytes
一键复制 编辑 原始数据 按行查看 历史
Sisyphus 提交于 2021-03-04 17:02 . note

Flink

  1. 统一数据处理组件栈,处理不同类型的数据需求(Batch、Stream、MachineLearning、Graph)。
  2. 支持事件时间(Event Time),接入时间(Ingestion Time),处理时间(Processing Time)等时间概念。
  3. 基于轻量级分布式快照(Snapshot)实现的容错,Checkpoint。
  4. 支持有状态计算:Support for very large state、querable state支持、灵活的state-backend(HDFS、内存、RocksDB)。。
  5. 支持高度灵活的窗口(Window)操作,Watermark。
  6. 带反压的连续流模型。
  7. 基于JVM实现独立的内存管理:Flink在JVM中实现了自己的内存管理。应用可以超出主内存的大小限制,并且承受更少的垃圾收集的开销。对象序列化二进制存储,类似于C对内存的管理。
Scala
1
https://gitee.com/sweetdream/flink-batch-stream.git
git@gitee.com:sweetdream/flink-batch-stream.git
sweetdream
flink-batch-stream
flink-batch-stream
master

搜索帮助