-
HBASE BufferedMutator 批量写入使用举例与源码解析
BufferedMutator主要用来异步批量的将数据写入一个hbase表,就像Htable一样。通过Connection获取一个实例。
大鹅 2023-01-02464 0 0 -
【Flink源码实战(一)】给Flink增加一个REST API
Flink官方实现了大量的REST API接口,有用于Flink UI展示数据、也用于各自监控面板。这些REST API的webserver作为JobManag...
皮皮熊 2023-01-02471 0 0 -
数仓数据处理DB基本概念解析与理解 OLAP OLTP HATP 异同 MPP架构
学习数仓的时候,可能一开始总是被一些英文缩写名字迷惑,OLAP MPP架构 KAPPA架构 ODS等等,这篇文章就来梳理一下这些基本概念。
大鹅 2023-01-02457 0 0 -
大数据Ambari自定义服务详细介绍
四年多前,入职一家大厂大数据部门主要工作就是从ambari集成大数据组件服务开始做起,当时需要把机器学习平台集成到大数据平台,当时把ambari进行了大量的修改...
house.zhang 2023-01-02442 0 0 -
大数据Apache Druid(三):Druid集群搭建
Druid进程可以以任意方式进行部署,为了方便部署,建议分为三种服务器类型:主服务器(Master)、查询服务器(Query)、数据服务器(Data)。
Lansonli 2023-01-02457 0 0 -
大数据ClickHouse(十):MergeTree系列表引擎之SummingMergeTree
该引擎继承了MergeTree引擎,当合并 SummingMergeTree 表的数据片段时,ClickHouse 会把所有具有相同主键的行合并为一行,该行包含...
Lansonli 2023-01-02468 0 0 -
kafka事务:入门篇
Kafka 的消息传输保障机制非常直观。当生产者向 Kafka 发送消息时,一旦消息被成功提交到日志文件,由于多副本机制的存在,这条消息就不会丢失。
皮皮熊 2023-01-02445 0 0 -
【腾讯云ES】Elasticsearch 分布式架构剖析及扩展性优化
Elasticsearch 是一个实时的分布式搜索分析引擎,简称 ES。一个集群由多个节点组成,节点的角色可以根据用户的使用场景自由配置,集群可以以节点为单位自...
黄华 2023-01-02455 0 0