flink学习37:DataStream/DataSet与Table的互相转换

news/2024/11/19 13:43:29/

DataStream/DataSet转换成视图

 

DataStream/DataSet转换成表

 

表转换成DataStream/DataSet

表转换为DataStream/DataSet时,需要指定字段数据类型,最方便的就是把数据类型定为row,即行数据。

 两种模式:

 

把表转为dataStream

 把表转为dataSet

 

流与表转变时,字段类型的转换

 基于位置的字段类型转换

 

基于名称的字段类型转换

原子属性的DataStream/DataSet转换为表

 Tuple类型的DataStream/DataSet转换为表

 

 

 

 

POJO类型的DataStream/DataSet转换为表

 

 row类型的DataStream/DataSet转换为表

 

 

 

示例:

 

 

 

 

 


http://www.ppmy.cn/news/63512.html

相关文章

java里面jdbc介绍

JDBC(Java Database Connectivity)是Java编程语言用于与关系型数据库进行交互的API(应用程序编程接口)。它提供了一组用于连接、执行查询和更新操作、处理事务等数据库操作的类和方法。 使用JDBC可以实现Java应用程序与各种关系型…

登录功能实现及文件上传下载功能补充

登录功能实现简单介绍: 1:登录时密码输入错误刷新登陆页面并提示登录信息错误; 2:输入正确用户名及密码点击sign in 登录成功。(如果勾选remember me 只要服务器未停止,可以直接免登录进入欢迎页面&#x…

【C++】类和对象(中)---构造函数和析构函数

个人主页:平行线也会相交💪 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 平行线也会相交 原创 收录于专栏【C之路】💌 本专栏旨在记录C的学习路线,望对大家有所帮助🙇‍ 希望我们一起努力、成长&…

七个值得推荐的物联网分析平台

物联网分析平台是一种软件工具,可以帮助企业收集和分析来自其广泛的物联网设备的数据。企业可以通过物联网收集大量数据,从消费者支出模式到流量使用,物联网数据分析平台在帮助企业获得竞争优势所需的洞察力方面至关重要。 物联网分析平台已…

《花雕学AI》用AI创造清晨的美好:ChatGPT+DALL-E 2 生成“早上好”的场景图

早晨是一天中最美好的时刻,也是最适合与AI对话的时刻。想象一下,当你醒来,打开手机,就能看到一个AI为你生成的“早上好”的场景图,是不是很温馨?这就是ChatGPTDALL-E 2(新Bing) 的魅…

MySQL完整性约束

主键约束 primary key :指定某个列作为表的主键,用来唯一标识每一行数据,主键值必须唯一且不为空(一个表只有一个主键,不可以为空,为空报错) 自增键约束 auto_increment : 常用的完整性约束&am…

系统集成项目管理工程师知识点总结

项目经理的五种权利: 职位权力: 来源于管理者在组织中的职位和职权。罚权力: 使用降职、扣薪、惩罚、批评、威胁等负面手段的能力。奖励权力: 给予下属奖励的能力专家权力: 来源于个人的专业技能。参照(号…

SpringBoot自动装配

Spring Boot 是一个基于 Spring 框架的开源框架,它简化了 Spring 应用的开发和部署,使得开发人员可以更加专注于业务逻辑的实现。其中一个重要的特性就是自动装配。 什么是自动装配? 自动装配是 Spring Boot 中的一个重要特性,它…