简介
大家都知道,Flink 是一个有状态的分布式流式计算引擎,flink 中的每个function或者是operator都可以是有状态的,为了使得状态可以容错,flink引入了checkpoint机制。checkpoint使得flink能够恢复作业的状态和位置,从而为作业提供与...
2年前 (2023-05-29) 2450℃
3喜欢
Future 介绍
Future 是Java5新加的一个接口,它提供了一种异步并行计算的功能。
如果主线程需要执行一个很耗时的计算任务,我们就可以通过future把这个任务放到异步线程中执行。主线程继续处理其他任务或者先行结束,在通过Future获取计算结果。
一句话:Futur...
2年前 (2022-12-07) 1428℃
0喜欢
前言
互联网架构设计有三高分别是,高可用,高扩展,高并发,本文主要以高并发设计为主来和大家分享互联网架构中的常用高并发手段。
高并发的考核指标
对于高并发的衡量有两个重要的指标:
吞吐量:表示架构每秒能抗多少并发
响应延迟:表示每个请求多久可以得到响应
系统性能优化...
4年前 (2020-07-12) 3035℃
4喜欢