最新 最热

Kubernetes 1.21引入Indexed Jobs特性

一旦你将一个非并行作业(Job[1])容器化,就很容易在 Kubernetes 上启动并运行它,而无需修改二进制文件。在大多数情况下,当运行并行分布式作业时,你必须设置一个单独的系统来在工作资源之间划分工作。例如,你可以设置一个任务...

2021-04-21
0

聊聊cheddar的MessageHandlerExecutor

Cheddar/cheddar/cheddar-messaging/src/main/java/com/clicktravel/cheddar/infrastructure/messaging/pooled/listener/MessageHandlerExecutor.java

2021-04-16
0

Java代码的编译过程

从Javac代码的总体结构来看,编译过程大致可以分为1个准备过程和3个处理过程,它们分别如下所示。

2021-04-14
0

Python多任务 - 进程

进程:一个程序运行起来后,代码 + 用到的资源称之为进程,它是操作系统分配资源的独立单位。

2021-04-13
0

干货分享 | 企业中为什么使用Flink异步IO!

Async I/O 是阿里巴巴贡献给社区的一个呼声非常高的特性,于1.2版本引入。主要目的是为了解决与外部系统交互时网络延迟成为了系统瓶颈的问题。

2021-04-13
0

Flink学习笔记(6) -- Flink Window和Time详解

聚合事件(比如计数、求和)在流上的工作方式与批处理不同。比如,对流中的所有元素进行计数是不可能的,因为通常流是无限的(无界的)。所以,流上的聚合需要由 window 来划定范围,比如 “计算过去的5分钟” ,或者 “最后100个元素...

2021-04-13
0

高并发数据结构Disruptor解析(6)

SequenceBarrier是消费者与Ringbuffer之间建立消费关系的桥梁,同时也是消费者与消费者之间消费依赖的抽象。

2021-04-12
0

2021-2-24:请问你知道 CPU SMP 架构么?

为了扩展单核 CPU 的性能,现在的服务器架构多采用多核 CPU 架构。一个比较经典的 CPU 架构就是对称多处理(Symmetric Multi-Processing,SMP)架构。与之相对应的就是非对称多处理(Asym-metrical Mulit-Processing)结构。...

2021-04-12
0

彻底搞清Flink中的Window(Flink版本1.8)

在流处理应用中,数据是连续不断的,因此我们不可能等到所有数据都到了才开始处理。当然我们可以每来一个消息就处理一次,但是有时我们需要做一些聚合类的处理,例如:在过去的1分钟内有多少用户点击了我们的网页。在这种情况...

2021-04-07
0

少写点if-else吧,它的效率有多低你知道吗?

我要再和生活死磕几年。要么我就毁灭,要么我就注定铸就辉煌。如果有一天,你发现我在平庸面前低了头,请向我开炮。

2021-03-25
0