240 发简信
IP属地:上海
  • Flink 源码之StreamTask

    Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 前言 本篇我们一起分...

  • 120
    log4j2自定义appender及rollover原理简析

    附上两个appender配置:RollingRandomAccessFileAppender和自定义的LogStoreAppender 自定义appender方式log4j2...

  • Thread.sleep和Object.notify

    public class SleepWaitTest extends Thread {@Overridepublic void run() {synchronized (th...

  • 120
    spring-jdbc之JdbcTemplate

    joiner里DbDataReader读数据用的spring-jdbc的JdbcTemplate,所以不用主动close资源连接之类的,JdbcTemplate里面会自动帮你...

  • 120
    spark基本工作原理

    1.spark基本工作原理 2.RDD 以及其特性a、RDD是Spark提供的核心抽象,全称为Resillient Distributed Dataset,即弹性分布式数据集...

  • 面向对象编程之Trait

    将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 ...

  • Collector源码分析

    java.util.stream.Collector是一个接口,作为stream对象collect(Collector collector)方法的参数,本身十分重要。jdk8...

  • Stream流介绍及实例

    通过流能更好地操作集合。java.util.Stream一般与lamda表达式结合使用。 1.流简介 流由三部分构成:源、0或多个中间操作、1个终止操作。 java.util...

  • mongo密集索引与稀疏索引

    密集索引 mongodb索引默认是密集型的。在一个有索引的集合里,每个文档都会有对应的索引项,哪怕文档中没有被索引键也是如此。例如,给文档的name字段建索引,而有的文档并没...