用例编号:CloudTestcase01 用例名称:可用性测试 测试原理:云计算功能发生变化,则应用程序应确保没有中断 执行步骤: St...
附上之前算子串烧[https://www.jianshu.com/p/37d7519bc31d]时的图,之前讲解的是中间的Transformat...
一、前言 1.1 写在前面 本文是在flask-adminlte基础上,结合了Echart,优化相关代码后发布的,做到“开箱即用”。 技术储备:...
一、Time Flink主要是做流式计算,数据是通过滚动(rolling)过来的,就像溪流一样,源源不断地进来。原文[https://ci.ap...
前言 如上图,算子,也叫operation或transformation,是编写业务逻辑的核心单元,类似于Spark中的RDD。 本文会参考Fl...
Flink是成熟的开源项目,关于概述资料很多,这里主要讲几点 一、Flink的前世今生 1、有三个重要时间点: 1.1 2009年,Flin...
前言 在Flink中比如某些算子(join,coGroup,keyBy,groupBy)要求在数据元上定义key。另外有些算子操作,例如redu...
一、基本概念 Spark 中最基本的数据抽象是 RDD,弹性分布式数据集 (Resilient Distributed DataSet)。 1....
一、Spark运行模式 1.1 local 本地模式:常用于本地开发测试 例如,程序中或-Master中传参数local[2]。SparkCon...