Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[//www.greatytc.com/p/d4a372809e3d] 前言 本篇我们一起分...
IP属地：上海
Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[//www.greatytc.com/p/d4a372809e3d] 前言 本篇我们一起分...
附上两个appender配置：RollingRandomAccessFileAppender和自定义的LogStoreAppender 自定义appender方式log4j2...
public class SleepWaitTest extends Thread {@Overridepublic void run() {synchronized (th...
joiner里DbDataReader读数据用的spring-jdbc的JdbcTemplate，所以不用主动close资源连接之类的，JdbcTemplate里面会自动帮你...
1.spark基本工作原理 2.RDD 以及其特性a、RDD是Spark提供的核心抽象，全称为Resillient Distributed Dataset，即弹性分布式数据集...
将trait作为接口使用Scala中的Triat是一种特殊的概念，可以将Trait作为接口来使用，此时的Triat就与Java中的接口非常类似。在triat中可以定义抽象方法...
1.定义类： 创建类的对象，调用其方法：val helloWorld = new HelloWorldhelloWorld.sayHello() //也可以不加括号pri...
1.if表达式 if表达式是有值的，就是if、else最后一行返回的值。 例：val age = 30; val isAdult = if (age > 18) 1 ...
java.util.stream.Collector是一个接口，作为stream对象collect(Collector collector)方法的参数，本身十分重要。jdk8...
通过流能更好地操作集合。java.util.Stream一般与lamda表达式结合使用。 1.流简介 流由三部分构成：源、0或多个中间操作、1个终止操作。 java.util...
密集索引 mongodb索引默认是密集型的。在一个有索引的集合里，每个文档都会有对应的索引项，哪怕文档中没有被索引键也是如此。例如，给文档的name字段建索引，而有的文档并没...
