Flink有7种数据类型分别是:

  1. Java Tuples and Scala Case Classes
  2. Java POJOs
  3. Primitive Types
  4. Regular Classes
  5. Values
  6. Hadoop Writables
  7. 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支持哪些数据类型相关推荐

  1. Apache Flink 零基础入门【转】

    Apache Flink 零基础入门(一):基础概念解析 Apache Flink 零基础入门(二):DataStream API 编程 转载于:https://www.cnblogs.com/dav ...

  2. python中5种简单的数据类型,Python小白零基础入门 —— 变量及简单的数据类型

    微信公众号:「Python读财」 若有问题或建议,请公众号留言 最近想着出一个Python小白零基础入门系列的文章,但愿能对入门的小伙伴有所帮助,内容会囊括简单的数据类型.列表.字典.循环以及函数的定 ...

  3. Apache Flink 零基础入门(十八)Flink Table APISQL

    什么是Flink关系型API? 虽然Flink已经支持了DataSet和DataStream API,但是有没有一种更好的方式去编程,而不用关心具体的API实现?不需要去了解Java和Scala的具体 ...

  4. Apache Flink 零基础入门(三)编写最简单的helloWorld

    实验环境 JDK 1.8 IDE Intellij idea Flink 1.8.1 实验内容 创建一个Flink简单Demo,可以从流数据中统计单词个数. 实验步骤 首先创建一个maven项目,其中 ...

  5. Apache Flink 零基础入门(十九)Flink windows和Time操作

    Time类型 在Flink中常用的Time类型: 处理时间 摄取时间 事件时间 处理时间 是上图中,最后一步的处理时间,表示服务器中执行相关操作的处理时间.例如一些算子操作时间,在服务器上面的时间. ...

  6. Apache Flink 零基础入门(一):基础概念解析

    Apache Flink 的定义.架构及原理 Apache Flink 是一个分布式大数据处理引擎,可对有限数据流和无限数据流进行有状态或无状态的计算,能够部署在各种集群环境,对各种规模大小的数据进行 ...

  7. Apache Flink 零基础入门(二十)Flink kafka connector

    内置source和sink 内置source包括从文件读取,从文件夹读取,从socket中读取.从集合或者迭代器中读取.内置的sink包括写文件.控制台输出.socket 内置connectors A ...

  8. Apache Flink 零基础入门(十五)Flink DataStream编程(如何自定义DataSource)

    数据源可以通过StreamExecutionEnvironment.addSource(sourceFunction)方式来创建,Flink也提供了一些内置的数据源方便使用,例如readTextFil ...

  9. Apache Flink 零基础入门(二十)Flink部署与作业的提交

    之前我们都是基于Idea在本地进行开发,这种方式很适合开发以及测试,但是开发完之后,如何提交到服务器中运行? Flink单机部署方式 本地开发和测试过程中非常有用,只要把代码放到服务器直接运行. 前置 ...

最新文章

  1. js异步提交form表单的解决方案
  2. linux 脚本 获取当前目录,Linux下获取脚本当前工作目录的一点感触
  3. Java正则表达式库基准测试– 2015年
  4. 夏季快速入睡的7个妙招
  5. python每隔30s检查一次_Python的全局解释器锁
  6. iPhone 13及12推动,机构预计苹果今年将销售近2亿部5G iPhone
  7. 六级词汇打卡第一天(一)
  8. 为什么开发环境如此之乱
  9. linux各个版本下载地址,利用镜像服务器下载
  10. 如何开发出一款仿映客直播APP项目实践篇 -【原理篇】
  11. js输出100以内的质数_用JS编写求出100以内的质数
  12. Ardunio——ULN2003驱动板和直流电机风扇——控制风扇转速
  13. 基于二叉树的家谱系统
  14. Photoshop的时间轴是灰色的,不能使的解决方法
  15. 17 重定向(Redirect) vs 转发(Forward)
  16. Ubuntu连接不了网络的解决方法亲测可行经验
  17. c语言 原子 字符串,Atomic operations library(原子操作库)
  18. Attempted to serialize java.lang.Class: com.cao.bean.DmCategory. Forgot to register a type adapter?
  19. 如何使用 AccessibilityService 实现蚂蚁森林自动收取能量,无需Root,无需连接电脑
  20. 思科2960接入华为S5130报错分析

热门文章

  1. 微信公众平台开发之微信access_token如何有效长期保存
  2. 学习 WCF (3)--开发WCF客户程序
  3. 深入学习__doPostBack函数
  4. Aspx页面转静态页面
  5. PHP的SOAP原理及实现
  6. CSS3的box-sizing:向外撑content-box向内挤border-box 外撑的padding算自己的盒子会变大 内挤的padding会缩小自己
  7. PHP之Session与Cookie:存放 安全 应用场景 过期设定 依赖关系
  8. PHP设计模式:工厂(静态方法里调用newobj的方法)单例(三私一公newself)注册树(使用静态变量数组存取对象)适配器(主体建立接口适配器丰富方法)
  9. Linux负载均衡Nginx六种策略
  10. mac编译php apache,在Mac OS上自行编译安装Apache服务器和PHP解释器