yiduwangkai

LV1
发表了文章

ganglia监控搭建

环境: CentOS release 6.2 (Final) 首先要下载ganglia http://sourceforge.net/projects/g...

yiduwangkai
发表了文章

flink(13)-flink on yarn源代码分析

session cluster和per job 因为是源码分析,所以会分为服务端和客户端两个部分的代码分析,下面我先看服务端<br/>

yiduwangkai
发表了文章

设计模式-里氏替换

先来看个最正宗的定义 如果对每一个类型为S的对象o1,都有类型为T的对 象o2,使得以T定义的所有程序P在所有的对象o1都代换成o2时,程序P的行为没有发生变 ...

yiduwangkai
发表了文章

设计模式-依赖倒置

yiduwangkai
发表了文章

hadoop ha搭建

修改zoo.cfg,创建对应的目录,在data目录下创建myid文件,一切完毕后进行启动

yiduwangkai
发表了文章

flink(12)-flink on yarn

flink yarn flink on yarn有两种模式,分别是session cluster和per job

yiduwangkai
发表了文章

设计模式-单例

登记模式:是为了克服饿汉式单例类及懒汉式单例类均不可继承的缺点而设计的。他的子类实例化的方式只能是懒汉式

yiduwangkai
JavaIDEHTTP
发表了文章

设计模式-六大设计原则(单一职责)

下面引用设计模式之蝉中的原话:“dial()和hangup()两个方法实现的是协议管理,分别负责拨号接通和挂机;chat()实现 的是数据的传送,把我们说的话转...

yiduwangkai
iPhoneiOS
订阅了专栏

腾讯云自媒体分享计划

3 文章3.6K 关注者
关注了用户

腾讯云自媒体分享计划

腾讯 · 产品运营 (已认证)

申请条件:至少有 20 篇或以上符合投稿要求可迁入腾讯云专栏的原创技术文章。

3 文章0 回答3.6K 关注者
发表了文章

netty(3)-译j2ee interceptingfilter

上下文 表示层请求处理机制接收许多不同类型的请求,这需要各种类型的处理。有些请求只是简单地转发到适当的处理程序组件,而其他请求必须先进行修改,审核或解压缩,然...

yiduwangkai
ServletJava编程算法
发表了文章

【转】一文看懂JVM内存布局及GC原理

杨俊明,携程云客服平台研发部软件技术专家。从事IT行业10余年,腾讯云+社区、阿里云栖社区、华为云社区认证专家。近年来主要研究分布式架构、微服务、Java技术等...

yiduwangkai
企业Java编程算法https网络安全
发表了文章

【译】如何调整ApacheFlink®集群的大小How To Size Your Apache Flink® Cluster: A Back-of-the-Envelope Calculation

来自Flink Forward Berlin 2017的最受欢迎的会议是Robert Metzger的“坚持下去:如何可靠,高效地操作Apache Flink”...

yiduwangkai
Kafka大数据
发表了文章

A Practical Guide to Broadcast State in Apache Flink

从版本1.5.0开始,Apache Flink具有一种称为广播状态的新型状态。 在这篇文章中,我们解释了广播状态是什么,并展示了如何将其应用于评估事件流上的动态...

yiduwangkai
大数据Apache
发表了文章

【译】Flink Network Stack Vol. 2: Monitoring, Metrics, and that Backpressure Thing

在之前的博文中,我们介绍了Flink的网络堆栈如何从高级抽象到低级细节。 此系列网络堆栈帖子中的第二篇博客文章扩展了这一知识,并讨论了监视与网络相关的指标,以识...

yiduwangkai
大数据
发表了文章

【译】A Deep-Dive into Flink's Network Stack(3)

单个 TaskManager 上的缓冲区总数通常不需要配置。需要配置时请参阅配置网络缓冲区文档。

yiduwangkai
缓存Java大数据文件存储
发表了文章

flink系列(11)-checkpoint的存储设计和实现

CheckpointStreamFactory/CheckpointOutputStream 接口提供了一套基层的状态存储的基础实现

yiduwangkai
发表了文章

【译】A Deep-Dive into Flink's Network Stack(2)

对于下图所示的示例,我们将假设4的并行性和具有两个任务管理器的部署,每个任务管理器提供2个插槽。 TaskManager 1执行子任务A.1,A.2,B.1和B...

yiduwangkai
大数据
发表了文章

【译】A Deep-Dive into Flink's Network Stack(1)

Flink的网络堆栈是组成flink-runtime模块的核心组件之一,是每个Flink工作的核心。 它连接所有TaskManagers的各个工作单元(子任务)...

yiduwangkai
大数据Windows
发表了文章

【译】Data exchange between tasks(任务之间的数据交换)

1.用于数据交换的控制流(即:为了启动交换而传递的消息)是接收者启动的,就像原始MapReduce一样

yiduwangkai
文件存储数据结构MapReduce

个人简介

个人成就

扫码关注云+社区

领取腾讯云代金券