响应式编程是一种面向数据流和变更传播的异步编程范式（Wikipedia(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fzh.wikipedia.org%2Fwiki%2F%25E5%2593%258D%25E5%25BA%2594%25E5%25BC%258F%25E7%25BC%

流的简介  官方解释，Stream是Java8的一大亮点，它与java.io包里的InputStream和OutputStream是完全不同的概念。它也不同于StAX对XML的解析的Stream，也不是AmazonKinesis对大数据实时处理的Stream。它是对集合对象功能的增强，她专注于对集合对象进行各种非常便利、高效的聚合操作(ag

Kafka作为时下最流行的开源消息系统，被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统，Kafka在保障了大部分功能特性的同时，还提供了超一流的读写性能。针对Kafka性能方面进行简单分析，相关数据请参考：https://segmentfault.com/a/1190000003985468(h

将行为作为数据传递函数编程的最直接的表现，莫过于将函数作为数据自由传递，结合泛型推导能力，使代码表达能力获得飞一般的提升。Java8怎么支持函数式编程？主要有三个核心概念：函数接口(Function)流(Stream)聚合器(Collector)函数接口关于函数接口，两件事：函数接口是行为

   之前一直在想如何读取一个class文件，并且获取其中的信息，Java有自己的_ClassLoader_,可以加载系统需要的class文件，或者用户自定义的class文件，但是对目录要求较高，需要时在classpath下,但是能不能将任意位置的class文件加载呢。   class文件是以二进制流的方式存在磁盘文件上的，ClassLoad

NIO与IO的区别NIO特点：非阻塞，面向缓冲区IO特点：阻塞式，面向流阻塞与非阻塞javaio是阻塞式的，当一个线程调用read或者write方法后开始阻塞，直到读取到数据或者写入数据完成，该线程一直处于阻塞状态不能做其他事情。javanio通过选择器实现非阻塞式IO，通过一个专门的选

在实际的业务中,我们经常会遇到数据迟到的情况,这个时候基于窗口进行计算的结果就不对了,Flink中watermark就是为了解决这个问题的,理解watermark之前,先来说一下flink中的三个与流数据相关的概念,ProcessTime、EventTime、IngestionTime,不然很难理解watermark是怎么回事.我们先来看一下官网给出的一

课程综述《ApacheFlink知其然，知其所以然》课程，在内容上会先对Flink整体架构和所适用的场景做一个基础介绍，让你对Flink有一个整体的认识！然后对核心概念进行详细介绍，让你深入了解流计算中一些核心术语的含义，然后对Flink各个层面的API，如SQL/Table&DataStreamAPI/PythonAPI进

说起Java8，我们知道Java8大改动之一就是增加函数式编程，而StreamAPI便是函数编程的主角，StreamAPI是一种流式的处理数据风格，也就是将要处理的数据当作流，在管道中进行传输，并在管道中的每个节点对数据进行处理，如过滤、排序、转换等。首先我们先看一个使用StreamAPI的示例，具体代码如下： !(htt

 一、浮动的性质1、浮动的元素脱离标准文档流，并且可以设置宽度和高度。2、浮动的元素相互贴靠3、浮动的元素有“文字环绕”效果       含有图片的div浮动，段落不浮动，文字会环绕图片。4、div浮动了且没有设置宽度，那么将自动收缩为内容的宽度。浮动（脱标）的元素是不能把容器惩处高度的。二、浮动的清除