flink基本程序架构

object TableApiTest {def main(args: Array[String]): Unit = {// TODO 1.创建环境val env = StreamExecutionEnvironment.getExecutionEnvironmentenv.setParallelism(1)val tableEnv = StreamTableEnvironment.create(env)// TODO 2.1 基于老版本planner的流处理val settings = EnvironmentSettings.newInstance().useOldPlanner().inStreamingMode().build()val oldStreamTableEnv = StreamTableEnvironment.create(env,settings)// TODO 2.2 基于老版本的批处理val batchEnv = ExecutionEnvironment.getExecutionEnvironmentval oldBatchTableEnv = BatchTableEnvironment.create(batchEnv)// TODO 2.3 基于blink planner的流处理val blinkStreamSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()val blinkStreamTableEnv = StreamTableEnvironment.create(env,blinkStreamSettings)// TODO 2.4 基于blink planner的批处理val blinkBatchSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()val blinkBatchTableEnv = TableEnvironment.create(blinkBatchSettings)}}

flink基本程序架构相关推荐

Flink运行时架构
1 运行时相关的组件 Flink运行时架构主要包括四个不同的组件:作业管理器(JobManager).资源管理器(ResourceManager).任务管理器(TaskManager),以及分 ...
Flink运行时架构完整使用 (第四章)
Flink运行时架构完整使用一.系统架构 1.整体构成 2.作业管理器(JobManager) 1. JobMaster 2. 资源管理器(ResourceManager) 3. 分发器(Disp ...
Qt学习笔记，Qt程序架构设计要旨
Qt学习笔记,Qt程序架构设计要旨时间过得很快,转眼学习Qt已经有一个多月了,对Qt的学习也在不断的深入中.自己手下的code也很多了,不过不得不说,还有很多的部分没有接触过,比如网络编程,2D,3 ...
python爬虫流程-Python爬虫程序架构和运行流程原理解析
1 前言 Python开发网络爬虫获取网页数据的基本流程为: 发起请求通过URL向服务器发起request请求,请求可以包含额外的header信息. 获取响应内容服务器正常响应,将会收到一个res ...
单线程与多线程网络程序架构简介
文章目录 1 单线程与多线程网络程序架构简介 1.1 服务端单线程处理多客户端 1.2 服务端多进程多端口处理多客户端 1.3 服务端多线程单端口分组处理多客户端 1.4 服务端多线程多端口分组处理多 ...
GUI应用程序架构的十年变迁:MVC,MVP,MVVM,Unidirectional,Clean
十年前,Martin Fowler撰写了GUI Architectures一文,至今被奉为经典.本文所谈的所谓架构二字,核心即是对于富客户端的代码组织/职责划分.纵览这十年内的架构模式变迁,大概可以分 ...
mpvue小程序架构搭建详细介绍
为什么80%的码农都做不了架构师?>>> 前言 mpvue小程序框架搭建很容易,官网提供vue init mpvue/mpvue-quickstart my-project, ...
让小程序在自有App中启动的技术来了：mPaaS小程序架构深度解析
简介:mPaaS 小程序框架作为一款 App 通用框架,帮助开发者面向自身的 App 实现小程序投放.不止如此,小程序代码仅需撰写一次,便可多端投放至自有 App.支付宝.钉钉甚至其他小程序开放平台. ...
从程序架构提升安全性
从程序架构提升安全性常见的程序架构有BS和CS之分一般 ,CS更安全-- 当然有时候必须得写成WEB程序--但是其中的管理后台可以做成CS的,以提升安全性. 在WEB程序上,我们的站可能被人挂马, ...

flink基本程序架构

flink基本程序架构相关推荐

最新文章

热门文章