Apache Flink 零基础入门(九)Flink支持哪些数据类型
Flink有7种数据类型分别是:
- Java Tuples and Scala Case Classes
- Java POJOs
- Primitive Types
- Regular Classes
- Values
- Hadoop Writables
- Special Types
Tuple
Tuple是一个组合数据类型,包含了固定数量的不同类别的字段。范围可以从Tuple0到Tuple25,表示包含的字段数量个数。
POJO
java和scala中定义POJO作用是一样的,POJO的类要满足以下条件:
- 必须用public修饰
- 必须要有一个public无参构造函数
- 所有字段要么是public的,要么必须要有setter和getter方法
- 类型必须是Flink支持的
Values
需要手动序列化和反序列化
Hadoop Writeables
必须是实现了org.apache.hadoop.Writable的类型。
Apache Flink 零基础入门(九)Flink支持哪些数据类型相关推荐
- Apache Flink 零基础入门【转】
Apache Flink 零基础入门(一):基础概念解析 Apache Flink 零基础入门(二):DataStream API 编程 转载于:https://www.cnblogs.com/dav ...
- python中5种简单的数据类型,Python小白零基础入门 —— 变量及简单的数据类型
微信公众号:「Python读财」 若有问题或建议,请公众号留言 最近想着出一个Python小白零基础入门系列的文章,但愿能对入门的小伙伴有所帮助,内容会囊括简单的数据类型.列表.字典.循环以及函数的定 ...
- Apache Flink 零基础入门(十八)Flink Table APISQL
什么是Flink关系型API? 虽然Flink已经支持了DataSet和DataStream API,但是有没有一种更好的方式去编程,而不用关心具体的API实现?不需要去了解Java和Scala的具体 ...
- Apache Flink 零基础入门(三)编写最简单的helloWorld
实验环境 JDK 1.8 IDE Intellij idea Flink 1.8.1 实验内容 创建一个Flink简单Demo,可以从流数据中统计单词个数. 实验步骤 首先创建一个maven项目,其中 ...
- Apache Flink 零基础入门(十九)Flink windows和Time操作
Time类型 在Flink中常用的Time类型: 处理时间 摄取时间 事件时间 处理时间 是上图中,最后一步的处理时间,表示服务器中执行相关操作的处理时间.例如一些算子操作时间,在服务器上面的时间. ...
- Apache Flink 零基础入门(一):基础概念解析
Apache Flink 的定义.架构及原理 Apache Flink 是一个分布式大数据处理引擎,可对有限数据流和无限数据流进行有状态或无状态的计算,能够部署在各种集群环境,对各种规模大小的数据进行 ...
- Apache Flink 零基础入门(二十)Flink kafka connector
内置source和sink 内置source包括从文件读取,从文件夹读取,从socket中读取.从集合或者迭代器中读取.内置的sink包括写文件.控制台输出.socket 内置connectors A ...
- Apache Flink 零基础入门(十五)Flink DataStream编程(如何自定义DataSource)
数据源可以通过StreamExecutionEnvironment.addSource(sourceFunction)方式来创建,Flink也提供了一些内置的数据源方便使用,例如readTextFil ...
- Apache Flink 零基础入门(二十)Flink部署与作业的提交
之前我们都是基于Idea在本地进行开发,这种方式很适合开发以及测试,但是开发完之后,如何提交到服务器中运行? Flink单机部署方式 本地开发和测试过程中非常有用,只要把代码放到服务器直接运行. 前置 ...
最新文章
- js异步提交form表单的解决方案
- linux 脚本 获取当前目录,Linux下获取脚本当前工作目录的一点感触
- Java正则表达式库基准测试– 2015年
- 夏季快速入睡的7个妙招
- python每隔30s检查一次_Python的全局解释器锁
- iPhone 13及12推动,机构预计苹果今年将销售近2亿部5G iPhone
- 六级词汇打卡第一天(一)
- 为什么开发环境如此之乱
- linux各个版本下载地址,利用镜像服务器下载
- 如何开发出一款仿映客直播APP项目实践篇 -【原理篇】
- js输出100以内的质数_用JS编写求出100以内的质数
- Ardunio——ULN2003驱动板和直流电机风扇——控制风扇转速
- 基于二叉树的家谱系统
- Photoshop的时间轴是灰色的,不能使的解决方法
- 17 重定向(Redirect) vs 转发(Forward)
- Ubuntu连接不了网络的解决方法亲测可行经验
- c语言 原子 字符串,Atomic operations library(原子操作库)
- Attempted to serialize java.lang.Class: com.cao.bean.DmCategory. Forgot to register a type adapter?
- 如何使用 AccessibilityService 实现蚂蚁森林自动收取能量,无需Root,无需连接电脑
- 思科2960接入华为S5130报错分析
热门文章
- 微信公众平台开发之微信access_token如何有效长期保存
- 学习 WCF (3)--开发WCF客户程序
- 深入学习__doPostBack函数
- Aspx页面转静态页面
- PHP的SOAP原理及实现
- CSS3的box-sizing:向外撑content-box向内挤border-box 外撑的padding算自己的盒子会变大 内挤的padding会缩小自己
- PHP之Session与Cookie:存放 安全 应用场景 过期设定 依赖关系
- PHP设计模式:工厂(静态方法里调用newobj的方法)单例(三私一公newself)注册树(使用静态变量数组存取对象)适配器(主体建立接口适配器丰富方法)
- Linux负载均衡Nginx六种策略
- mac编译php apache,在Mac OS上自行编译安装Apache服务器和PHP解释器