240 发简信
IP属地:北京
  • zookeeper

    zk的核心: ZNode, Watcher机制; zk的应用场景: 发布订阅命名服务集群管理分布式锁分布式队列管理负载均衡配置管理 分布式队列管理 与 时序锁 // ...

  • 5、kafk数据的Exactly once

    kafka数据可靠性[https://www.jianshu.com/p/75ec3e1145d5],用ack来保证,有0值,1值,和-1值,生产环境需要根据实际情况来配置,...

  • 4、kafka消息一致性

    考虑如下一个问题:某个topic下的某个partition, 假设他有3个副本(1个leader,2个follower);在某个时刻,leader里有100条数据, 第1个f...

  • 3、kafka消息可靠性

    数据可靠性 当producer发送消息给kafka集群,如何保证数据发送过去了呢? 这就需要kafka集群在收到消息时给producer一个反馈, 当producer收到这个...

  • 数据仓库学习笔记

    按顺序要了解:数仓是什么、数仓是干什么、数仓具体是怎么做 一. 数仓是什么(了解基本概念) 略 二. 数仓是干什么(了解自己的工作内容在公司所处的定位) 数据仓库研发规范概述...

  • 2、安装ohmyzsh

    官网:https://ohmyz.sh/#install[https://ohmyz.sh/#install] 官网安装会报错443的错误,需要换一个源: 这是一个包装mac...

  • 120
    1、homebrew的介绍与使用

    homebrew官网:https://brew.sh/[https://brew.sh/]homebrew是macos(或linux)缺失的软件包管理器。 简介一般来讲,我们...

  • 120
    0、安装homebrew

    以上是我自己电脑上安装homebrew的过程截图,中间有一步骤下载数据特别慢,提示远程终端挂起,导致下载失败,不过失败后会自动切换源重新下载(需要再次输入mac密码),然后等...

  • 工作中用到的参数

    set datasync.input.table.encrypt=true;用于在ks_db_origin_encrypt(这种为加密表)的解密 set hive.fetch...

  • Flink笔记2020-02-23

    Apache Flink是由Apache软件基金会开发的开源流处理框架。其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和流水线方式执行任意流数据...

  • 120
    数据库连接池

    1、数据库辅助类 以上连接方式有个问题:用户每次请求都要获取数据库连接,而数据库创建连接的创建是非常消耗资源的。如果访问量过多,创建的连接数也会递增,极易造成数据库服务器的内...

  • 120
  • ClickHouse

    ClickHouse是俄罗斯的Yandex于2016年开源的列式存储数据库(DBMS), 主要用于在线分析处理查询(OLAP), 能够使用SQL查询实时生成分析数据报告。 1...

  • 120
    13、scala集合

    基本介绍 Scala同时支持不可变集合(immutable)和可变集合(mutable), 不可变集合可以安全滴并发访问。ps:一般情况下建议使用不可变集合。scala默认采...

  • 11、scala嵌套类

    在scala中,你几乎可以在任何语法结构中嵌套任何语法结构。 如在类中可以再定义一个类,这样的类是嵌套类,其他语法接口也是一样。嵌套类,类似于java的内部类。

  • 10、trait的动态混入 及 trait的叠加

    1、问题引入 问题引入:可以看到上面的代码,Person类从MyTrait继承的函数,也被传递给了Person的子类!目的:想让Person类拥有MyTrait函数,而不想让...

  • Jenkins

    1、软件开发过程 开发过程中最好有以下这3个保持:持续部署:自己的代码不停滴再写,要持续滴部署自己的代码到服务器上,并且可以运行!持续集成:自己的代码部署且能运行后,还需要集...

  • 120
    9、scala的trait

    简介 trait,中文意思"特质"。scala中叫"特质", 有的人也叫"特征"。scala中的trait相当于java中的"接口+抽象类"java的抽象类既可以有抽象方法也...