Flink 数据类型

Flink使用类型信息的概念来表示数据类型，并为每个数据类型生成特定的序列化器、反序列化器和比较器。但是，在某些情况下，例如lambda函数或泛型类型，需要显式地提供类型信息，才能使应用程序正常工作或提高其性能。

1.Java基础类型
Int, Double, Long, String, …
2.Java元组（Tuples）
3.Java简单对象（POJOs）

public class Person {public String name;
public int age;public Person() {}public Person(String name, int age) {
this.name = name;
this.age = age;
}
}
DataStream<Person> persons = env.fromElements(
new Person("Wang", 16),
new Person("Wei", 22));

4.其它（Arrays, Lists, Maps, Enums, 等等）
比如Java的ArrayList，HashMap，Enum等等

1.Scala基础类型
Int, Double, Long, String, …
2.Scala元组
3.Scala样例类（case classes）
4.Scala的（Arrays, Lists, Maps, Enums, 等等）

Flink 数据类型相关推荐

java中row类,Flink数据类型之POJO和Table中的Row
Published: 2019-09-15 22:10:00 tags: Flink Flink数据类型支持 TypeInformation主要是为Flink系统内有效的对数据结构类型进行管理, 对数 ...
Flink 1.12的CDC
基于Flink构建流批一体的实时数仓是目前数据仓库领域比较火的实践方案.随着Flink的不断迭代,其提供的一系列技术特性使得用户构建流批一体的应用变得越来越方便.本文将以Flink1.12为例,一一介 ...
Flink学习4-流式SQL
Flink学习4-流式SQL Flink系列文章更多Flink系列文章请点击Flink系列文章更多大数据文章请点击大数据好文推荐摘要介绍Flink Table Sql API相关概念,还会提供 ...
Flink教程（01）- Flink知识图谱
文章目录 01 引言 02 Flink 知识结构 2.1 Flink介绍 2.2 环境准备 2.3 Flink编程模型 2.4 DataStream API 2.5 Flink状态管理和容错 2.6 ...
Flink学习1-基础概念
Flink学习1-基础概念 Flink系列文章更多Flink系列文章请点击Flink系列文章更多大数据文章请点击大数据好文推荐摘要本文是作者学习Flink的一些文档整理.记录和心得体会,希望与 ...
11 编程指南_流数据
Flink 的流数据 API 编程指南 Flink 的流数据处理程序是常规的程序 ,通过再流数据上,实现了各种转换 (比如过滤, 更新中间状态, 定义窗口, 聚合).流数据可以来之多种数据源 (比如 ...
flink-sql所有表连接器-1.15
1. 版本说明本文档内容基于flink-1.15.x,其他版本的整理,请查看本人博客的 flink 专栏其他文章. 2. 简介 2.1. 介绍 Flink的Table API和SQL程序可以连接到其 ...
Apache Flink 零基础入门（九）Flink支持哪些数据类型
Flink有7种数据类型分别是: Java Tuples and Scala Case Classes Java POJOs Primitive Types Regular Classes Value ...
Flink之数据类型和序列化
本文根据 Apache Flink 系列直播整理而成,由 Apache Flink Contributor.360 数据开发高级工程师马庆祥老师分享.文章主要从如何为Flink量身定制的序列化框架.F ...

Flink 数据类型

Flink 数据类型相关推荐

最新文章

热门文章