240 发简信
IP属地:广东
  • @群演_ 增加一些DDL语句,当前它提供的不能满足~~

    Calcite 原理解析

    Apache Calcite 是独立于存储与执行的SQL解析、优化引擎,广泛应用于各种离线、搜索、实时查询引擎,如Drill、Hive、Kylin、Solr、flink、Sa...

  • @群演_ 在flink中只有Calcite的sql解析引擎吧??

    Calcite 原理解析

    Apache Calcite 是独立于存储与执行的SQL解析、优化引擎,广泛应用于各种离线、搜索、实时查询引擎,如Drill、Hive、Kylin、Solr、flink、Sa...

  • 大神,Calcite怎么自定义一些SQL语句呢??

    Calcite 原理解析

    Apache Calcite 是独立于存储与执行的SQL解析、优化引擎,广泛应用于各种离线、搜索、实时查询引擎,如Drill、Hive、Kylin、Solr、flink、Sa...

  • 谢谢分享

    大公司开源项目

    阿里,百度,腾讯,360,新浪,网易,小米等 文章汇总:https://www.cnblogs.com/dotnetcrazy/p/9160514.html 目录: 特点: ...

  • 120
    Yarn调度队列

    1 概述 在Yarn中,负责给应用分配资源的是Scheduler,并提供了多种调度器和可配置的策略供选择。在Yarn中有是三种调度器可以选择:FIFO Scheduler,C...

  • 120
    Yarn资源隔离

    1 概述 1.1 基本概念 ** A.ResourceManager ** ResourceManager 是一个全局的资源管理器,负责整个集群的资源管理和分配。它主要由两个...

  • CAS和AQS

    1 CAS 什么是CAS? 如在多线程中实现自增,会出现线程安全问题,要解决这个问题,需要通过加锁的方式,调整如下: 这类似于悲观锁的实现,我需要获取这个资源,那么我就给他加...

  • @Java耕耘者 好的~

    Java知识点杂谈

    0 概述 Channel是一个对象,可以通过它读取和写入数据。拿 NIO 与原来的 I/O 做个比较,通道就像是流,而且他们面向缓冲区的。所有数据都通过 Buffer 对象来...

  • 120
    Lucene底层原理

    1 索引原理 全文索引由来已久,绝大多数都基于倒排索引来做,顾名思义,它与常规的一篇文章包含哪些词相反,它是一个词记录到那些文档中,由两部分组成--词典和倒排表。其中词典结构...

  • 120
    Hbase BlockCache

    1 LRU Cache LRUBlockCache是目前hbase默认的BlockCache机制,实现机制也比较简单,是使用一个ConcurrentHashMap管理Bloc...

  • 120
    Kafka源码分析

    1 消息处理入口 以下是Kafka消息处理的入口,即客户端发送到服务端消息处理方法。 2 内存中offset信息来源 从上面代码中可以看出,拉取的offset是从offset...

  • Java中的Future

    1 概述 Future代表异步计算返回的结果,提供了检查是否结束、等待结束以及获取计算结果的方法。Executor框架使用Runnable作为其任务表示形式,但它不能返回一个...

  • Join优化

    概述 跟传统的关系型数据库类似,分布式环境中的join在提供优化器“hint”(提示)以告诉优化器选择一些执行策略。目前一些优化提示主要针对批处理中的连接(join)。在批处...

  • 120
    Netty内存模型-PoolArena

    1 原理 应用层的内存分配最终是委托给PoolArena实现。先看下PoolArena的内部数据结构: poolArena提供了两种方式进行内存分配: PoolSubpage...

  • 120
    Netty内存模型-PoolChunk

    1概述 从netty 4开始,netty加入了内存池管理,采用内存池管理比普通的new ByteBuf性能提高了数十倍。首先介绍PoolChunk 2原理 PoolChunk...

  • 120
    Credit-based Flow Control

    1 概述 随着网络规模和应用的快速增长,拥塞已经成为一个日益重要而突出的问题。尽管拥塞控制策略已经广泛应用,但是提高网络吞吐还是一个重要方向,本文介绍一种基于信用的流量控制方...

  • 120
    Flink异步I/O

    1 概述 流计算系统中经常需要与外部系统进行交互,我们通常的做法如向数据库发送用户a的查询请求,然后等待结果返回,在这之前,我们的程序无法发送用户b的查询请求。这是一种同步访...

  • 120
    端到端exactly-once(翻译官方)

    1 概述 在Flink1.4.0中,发布了一个叫做TwoPhaseCommitSinkFunction的特性,该逻辑抽取两阶段提交协议常规逻辑,使得可以构建端到端的exact...

  • Java四种引用

    1概述 在JDK 1.2以前的版本中,若一个对象不被任何变量引用,那么程序就无法再使用这个对象。也就是说,只有对象处于可触及(reachable)状态,程序才能使用它。从JD...

个人介绍
持续更新大数据相关知识点,关注Hadoop、Spark、Flink等技术