首页
首页
沸点
课程
直播
活动
竞赛
商城
APP
插件
搜索历史
清空
创作者中心
写文章
发沸点
写笔记
写代码
草稿箱
创作灵感
查看更多
会员
登录
注册
coderLJ
掘友等级
获得徽章 0
动态
文章
专栏
沸点
收藏集
关注
作品
赞
30
文章 30
沸点 0
赞
30
返回
|
搜索文章
赞
文章( 30 )
沸点( 0 )
9.Flink 分布式缓存
1.分布式缓存1.1介绍1.1.1技术细节1.1.2案例设计1.2实操1.2.1前提1.2.2代码实现1.2.3测试开启源控制台输出1.2.4Flink分布式缓存中从远程hdfs上下载资源到TaskM
10. Flink 状态管理与检查点机制
1. Flink 状态管理 相对于其他流计算框架,Flink 一个比较重要的特性就是其支持有状态计算。即你可以将中间的计算结果进行保存,并提供给后续的计算使用: 算子状态 (Operator State):顾名思义,状态是和算子进行绑定的,一个算子的状态不能被其他算子所访问到。…
12. Flink窗口模型
streaming流式计算是一种被设计用于处理无限数据集的数据处理引擎,而无限数据集是指一种不断增长的本质上无限的数据集,而window是一种切割无限数据为有限块进行处理的手段。 Window是无限数据流处理的核心,Window将一个无限的stream拆分成有限大小的”buck…
8.Flink 广播变量\累加器
1. 广播变量 在Flink中,同一个算子可能存在若干个不同的并行实例,计算过程可能不在同一个Slot中进行,不同算子之间更是如此,因此不同算子的计算数据之间不能像Java数组之间一样互相访问,而广播变量Broadcast便是解决这种情况的. 在 flink 中,针对某一个算子…
k8s部署SpringCloud G版 provider
idea创建一个 Spring Initializr 工程,并命名为 msc-provider-8081。导入 Lombok、Web、JPA 及 MySQL 驱动依赖。 [root@master01 provider]# docker build -t microservice…
k8s部署SpringCloud G版组件Zuul
网关是系统唯一对外的入口,介于客户端与服务器端之间,用于对请求进行鉴权、限流、 路由、监控等功能。 Zuul和Eureka进行整合,将Zuul自身注册为Eureka服务治理下的应用,同时从Eureka中获得其他微服务的消息,也即以后的访问微服务都是通过Zuul跳转后获得。 这里…
k8s部署SpringCloud G版组件hystrix
Hystrix是一个用于处理分布式系统的延迟和容错的开源库,在分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,Hystrix能够保证在一个依赖出问题的情况下,不会导致整体服务失败,避免级联故障,以提高分布式系统的弹性。 “断路器”本身是一种开关装置,当Hystri…
k8s部署SpringCloud G版组件config
1. spring cloud config 概述 Spring Cloud Config 就是对微服务的配置文件进行统一管理的。其工作原理是,我们首 先需要将各个微服务公共的配置信息推送到 GitHub 远程版本库。然后我们再定义一个 Spring Cloud Config …
0.编译flink1.9.0源码 报flink-fs-hadoop-shaded找不到
maven 编译的时候跳过这些检查,这样可以减少很多时间,还可能会减少错误的发生。 注意:你的 maven 的 settings.xml 文件的 mirror 添加下面这个(这样才能下载到某些下载不了的依赖)。
8.Gateway新一代网关
1. 概述 Gateway是SpringCloud的一个全新项目,基于Spring5+SpringBoot2 和Project Reactor等技术开发的网关。Gateway旨在为微服务架构提供一种简单而有效的API路由管理方式。 SpringCloud Gateway作为Sp…
下一页
个人成就
文章被点赞
45
文章被阅读
43,174
掘力值
878
关注了
12
关注者
11
收藏集
0
关注标签
8
加入于
2020-02-25