【Flink】Table\Sql API 笔记：Row和RowData-Toy模板网

这篇具有很好参考价值的文章主要介绍了【Flink】Table\Sql API 笔记：Row和RowData。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

根据个人理解整理，大佬们有更好的想法可以评论

首先，Row是一种固定长度、可识别空值的复合类型，使用确定的字段顺序存储多个值。无论字段的类型如何，每个字段都可以为空。无法自动推断行字段的类型；因此，无论何时生成一行，都需要提供类型信息。
Row 的主要目的是在 Flink 的 Table 和 SQL 生态系统以及其他 API 之间架起一座桥梁。因此，行不仅由模式部分（包含字段）组成，而且还附加了一个 RowKind 用于对更改日志中的更改进行编码。因此，可以将一行视为更改日志中的一个条目。例如，在常规批处理方案中，更改日志将包含 RowKind.INSERT 行的有界流。行种类与字段分开，可以使用 getKind() 和 setKind(RowKind) 访问。

Row有三种模式：

Position-based field mode：根据位置设置field

Name-based field mode：根据fieldName设置

Hybrid / named-position field mode：混合模式

RowData

首先，RowData是一个接口噢，有很多基于接口的实现，其中可以看下GenericRowData的构造函数，基本就明白了，传入rowKind以及参数个数。RowData是在运行时通过 Table API 或 SQL 管道传输的所有顶级接口。

  private final Object[] fields;
  private RowKind kind;

  public GenericRowData(RowKind kind, int arity) {
    this.fields = new Object[arity];
    this.kind = kind;
  }

所以总结下来可以这样理解，Row为RowData的低阶数据类型，常常用于DataStream中的使用；而RowData是通过不同的Conveter转换Row得到的高阶数据，用于TableAPI和Sql中使用；两者中的存储内容基本是一致的。文章来源地址https://www.toymoban.com/news/detail-628479.html

到了这里，关于【Flink】Table\Sql API 笔记：Row和RowData的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！