当前位置: 首页 > news >正文

Flink基础

目录

  • Flink的特点
  • Flink流处理简介
    • Flink是什么
    • Flink的应用场景
    • 为什么选择Flink
  • 分层API

Flink的特点

结果正确
高吞吐
高容错
易用的API
低延迟
语义化窗口

在这里插入图片描述

Flink流处理简介

Flink跟Spark的主要区别:
Flink做的是流处理,而Spark主要做的是批处理

Flink是什么

Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行状态计算

Flink的应用场景

物联网:
实时数据采集
实时报警

银行和金融业:
实时结算
风险检测

电商和市场营销:
实时报表
广告投放
实时推荐

物流配送及服务
订单状态跟踪
信息推送

在这里插入图片描述

为什么选择Flink

批处理和流处理
流处理更真实反映了我们的生活方式
我们的目标:
低延迟、高吞吐、结果的准确性和良好的容错性

lambda架构:
用两套系统,同时保证低延迟和结果准确
在这里插入图片描述

分层API

越顶层越抽象,表达含义越简明,使用越方便
越底层越具体,表达能力越丰富,使用越灵活

在这里插入图片描述

http://www.dtcms.com/a/342110.html

相关文章:

  • 解锁工业级Prompt设计,打造高准确率AI应用
  • Web自动化测试:测试用例流程设计
  • Java设计模式-解释器模式
  • 策略模式 vs 适配器模式
  • 基于STM32设计的大棚育苗管理系统(4G+华为云IOT)_265
  • 移动应用抓包与调试实战 Charles工具在iOS和Android中的应用
  • 数据结构初阶:详解二叉树(三):链式二叉树
  • system\core\init\init.cpp----LoadBootScripts()解析init.rc(1)
  • STM32之串口详解
  • 学习Linux嵌入式(正点原子imx课程)开发到底是在学什么
  • Spring Cloud Netflix学习笔记06-Zuul
  • Kafka消息持久化机制全解析:存储原理与实战场景
  • Kafka集成Flume
  • 人工智能 -- 循环神经网络day1 -- 自然语言基础、NLP基础概率、NLP基本流程、NLP特征工程、NLP特征输入
  • 算法 之 拓 扑 排 序
  • LeetCode 回文链表
  • 桥梁设计模式
  • RabbitMQ事务消息原理是什么
  • RabbitMQ:延时消息(死信交换机、延迟消息插件)
  • 领域专用AI模型训练指南:医疗、法律、金融三大垂直领域微调效果对比
  • 28、工业网络资产漏洞扫描与风险评估 (模拟) - /安全与维护组件/industrial-network-scanner
  • 深度解析Atlassian 团队协作套件(Jira、Confluence、Loom、Rovo)如何赋能全球分布式团队协作
  • Whisk for Mac 网页编辑器 PHP开发
  • 牛客:链表的回文结构详解
  • NewsNow搭建喂饭级教程
  • SQL中对视图的操作命令汇总
  • STM32H750 CoreMark跑分测试
  • [最新]Dify v1.7.2版本更新:工作流可视化和节点搜索
  • 2025 年 8 月《GPT-5 家族 SQL 能力评测报告》发布
  • SQL视图、存储过程和触发器