前言:掌握Hbase的重要性不言而喻,掌握Hbase的设计原理更是重中之重。本文是对HBase原理进行讲解系列文章的开篇,本文尽量详细的从整体上介绍HBase的架构,并对每个...
在新建一个Consumer时,我们可以通过指定groupId来将其添加进一个Consumer Group中。Consumer Group是为了实现多个Consumer能够并行...
写的很好, 直观, 谢谢.
Kafka offset管理Kafka中的每个partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到partition中。partition中的每个消息都有一个连续的序号,用于pa...
Kafka中的每个partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到partition中。partition中的每个消息都有一个连续的序号,用于pa...
Mysql数据库的安装对于开发者来说,是我们必然会面对的问题,它的安装过程其实并不复杂,并且网络上的安装教程也非常多,但是对于新手来说,各种不同形式的安装教程,又给新手们带来...
现在是1.12, 变化好大啊, 入口都变了, /(ㄒoㄒ)/
Apache Flink 源码解析(二)(Legacy mode已废弃)系统架构, 启动与注册概述 这篇文章侧重于分析JobManager和TaskManager的启动过程以及注册,还有Flink的implementation中所用到的设计模式。本文从本地与stand...
概述 Flink内部有一些服务是JobMaster和TaskExecutor共用的。如HighAvailabilityServices, RpcService, ActorS...
概述 根据上一篇文章 DataStream API 可以得知每一个方法生成的Transformation和实际运行中对Task的影响。事实上从Transformation到实...
谢谢谢谢谢谢谢谢谢, 我还一直傻傻的把env.execute()当作入口
Apache Flink 源码解析(一)(Legacy mode已废弃)入口,bash脚本概述 因为自己在阅读源码的过程中曾经遇到过很多问题,现在稍微有一点点的经验希望分享给很多从零开始的人。Apache的项目代码量很大,很难做到彻底通读,我也是一步一步的先从整体...
最近参加了字节跳动的后台开发工程师面试,记录一下面经。(ps:社招两年经验) 1. 一面(1小时) 一面主要是基础考察,包括简历中提到的以及一些标准的基础问题。 VUE和Re...
AOP(Aspect Orient Programming),作为面向对象编程的一种补充,广泛应用于处理一些具有横切性质的系统级服务,如事务管理、安全检查、缓存、对象池管理等...