What can be Streamed

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: What can be StreamedFlink用于Java和Scala的DataStream APIs将允许传输他们可以序列化的任何内容。Flink的序列化器用于:简单类型:String,Long,integer,Boolean,Array复合类型:Tuples,POJOs,Scala case classes而Flink对于其他类型则回归于Kryo。

What can be Streamed

Flink用于Java和Scala的DataStream APIs将允许传输他们可以序列化的任何内容。

Flink的序列化器用于:

  • 简单类型:String,Long,integer,Boolean,Array
  • 复合类型:Tuples,POJOs,Scala case classes

而Flink对于其他类型则回归于Kryo。

Java

Tuples

对于Java而言,Flink定义了Tuple1到Tuple25类型。

Tuple2<String, Integer> person = new Tuple2<>("Fred", 35);

// zero based index!
String name = person.f0;
Integer age = person.f1

POJOs

一个POJOs(普通的旧Java对象)是任何Java类:

  • 有一个空的默认构造函数
  • 所有域都是以下之一:
    • public
    • 有一个默认的getter和setter

例如:

public class Person {
    public String name;
    public Integer age;
    public Person() {};
    public Person(String name, Integer age) {
        ...
    };
}

Person person = new Person("Fred Flintstone", 35);

Scala tuples和 case classes

这些工作正如您所期望的那样。

相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
目录
相关文章
|
9月前
|
JavaScript
如何在 Vue 中进行表单验证?
如何在 Vue 中进行表单验证?
77 0
|
9月前
|
前端开发
TS声明promise返回来的数据类型
TS声明promise返回来的数据类型
|
9月前
|
JavaScript Java 测试技术
基于Java的经典电影推荐网站的设计与实现(源码+lw+部署文档+讲解等)
基于Java的经典电影推荐网站的设计与实现(源码+lw+部署文档+讲解等)
132 1
|
6月前
|
数据可视化
Echarts数据可视化开发| 智慧营业厅
Echarts数据可视化开发| 智慧营业厅
|
9月前
|
前端开发 网络协议 Go
为什么ChatGPT选择了SSE,而不是WebSocket?
为什么ChatGPT选择了SSE,而不是WebSocket?
367 2
|
9月前
如何将Doris的COLLECT_LIST结果用在另一个查询的条件语句里
【4月更文挑战第21天】如何将Doris的COLLECT_LIST结果用在另一个查询的条件语句里
237 0
|
存储 弹性计算 文件存储
快速学会使用对象存储OSS
本场景带您体验如何通过对象存储OSS控制台完成场景的基础操作。
|
应用服务中间件 Linux nginx
重识Nginx - 06 搭建静态资源Web服务器(alias VS root)
重识Nginx - 06 搭建静态资源Web服务器(alias VS root)
284 0
|
SQL 消息中间件 缓存
基于 Flink SQL CDC 的实时数据同步方案
Flink 1.11 引入了 Flink SQL CDC,CDC 能给我们数据和业务间能带来什么变化?本文由 Apache Flink PMC,阿里巴巴技术专家伍翀 (云邪)分享,内容将从传统的数据同步方案,基于 Flink CDC 同步的解决方案以及更多的应用场景和 CDC 未来开发规划等方面进行介绍和演示。
基于 Flink SQL CDC 的实时数据同步方案
|
物联网
ICA联盟生态的进阶之路
IoT合作伙伴计划联盟(IoT Connectivity Alliance),简称ICA联盟,是阿里巴巴联合物联网产业合作伙伴建立的物联网标准联盟,目的是共同发展完善物联网相关的技术,共建相关的联盟标准,推动国家标准和国际标准,促进物联网行业的快速、健康发展。
6014 0