Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 前言 本篇我们一起分...
Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.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字段建索引,而有的文档并没...