AQS 全称是 Abstract Queued Synchronizer,一般翻译为同步器。它是一套实现多线程同步功能的框架。AQS 在源码中被广泛使用,尤其是在 JUC(J...

IP属地:北京
AQS 全称是 Abstract Queued Synchronizer,一般翻译为同步器。它是一套实现多线程同步功能的框架。AQS 在源码中被广泛使用,尤其是在 JUC(J...
DataStream 1. map/flatMap MapFunction<T, O> 输入一个元素,输出一个元素,其中包含了变换逻辑 RichMapFunction 继承了...
flink内部通信机制 Operator间的数据传递本地线程数据传递远程线程数据传递同一线程的Operator数据传递 Buffer读写Buffer读取Buffer写入 内存...
这篇文章以flink官方local cluster教程为主线,引导大家体验一下flink的初次开发。文章中所提到的代码我已经放到github上,欢迎指正。 下载和启动Flin...
1.概念 低阶API process function,越底层越丰富复杂,提供了对状态的管理中阶API DataStream API,一般都是使用这个高级API ...
原创:阿飞的博客 好吧,可能某些项目还在使用dubbo,但是你也一定听过Spring Cloud。至于Spring和Spring Boot,对于现在的Java开发,它们的地位...