FlinkFlink Row类型转Table类型

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink Row类型转Table类型相关的知识,希望对你有一定的参考价值。

文章目录


1.概述

一个网友想flink DataStreamSource<ROW> 怎么转为表,但是总是报错


具体代码大概如下


然后我就去研究了一下 ,写了如下几种方案

2.测试

2.1 方案1

/*

以上是关于FlinkFlink Row类型转Table类型的主要内容,如果未能解决你的问题,请参考以下文章

查询Mysql表之后将结果转换为json时如何能够保持字段的原有数据类型?

FLinkFlink SQL 解析嵌套的 JSON 数据

MYSQL_ROW 和 row[0] 到字符串类型?

SQL xml转table

FlinkTableSql API 笔记:Row和RowData

C# 索引器,实现IEnumerable接口的GetEnumerator()方法