【flink】RowData copy/clone方式

向右看齐 2024-02-20 12:12 134阅读 0赞

说明：一般用户常用的是`GenericRowData`。flink内部则多使用`BinaryRowData`。

#### 方法一、循环解决(不推荐)： ####

代码较为复杂需要根据`RowType`获取到内部fields的logicalType，再使用`RowData.createFieldGetter`方法创建`fieldGetters`。

public static void copyRowData(RowData input, GenericRowData output, List<RowData.FieldGetter> fieldGetters) {
        
            for (int i = 0; i < input.getArity() && i < output.getArity(); i++) {
        
                if (input instanceof GenericRowData) {
        
                    output.setField(i, ((GenericRowData) input).getField(i));
                } else {
        
                    Preconditions.checkArgument(fieldGetters != null);
                    Object value = fieldGetters.get(i).getFieldOrNull(input);
                    output.setField(i, value);
                }
            }
        }

#### 方法二、使用RowDataSerializer(推荐) ####

使用`RowDataSerializer.copy`方法

public RowDataSerializer(RowType rowType) {
        
    ...
    }
    
    public RowData copy(RowData from) {
        
    ...
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，134人围观）

还没有评论，来说两句吧...

相关阅读

相关交换机的4种网络结构方式：级联方式、堆叠方式、端口聚合方式、分层方式

交换机是计算机网络中重要的网络设备之一，用于实现局域网（LAN）内部的数据转发和通信。交换机可以采用不同的网络结构方式来满足不同的网络需求和拓扑结构。本文将详细介绍交换机的四种

不念不忘少年蓝@/ 2024年03月16日 11:26/ 0 赞/ 181 阅读

相关负载方式

在各大网站中常用的负载方式： HaProxy：常用来进行网络第四层（TCP层进行负载） nginx：常用来进行网络第七层（即Http层负载），现在已经可以进行第四层负载；

忘是亡心i/ 2023年06月07日 05:34/ 0 赞/ 72 阅读

相关中断方式与轮询方式

中断方式与轮询方式标签（空格分隔）：计算机 -------------------- > 原文链接：[http://lionwq.spaces.eepw.com.

梦里梦外;/ 2023年06月02日 14:55/ 0 赞/ 123 阅读

相关线程的几种实现方式?启动方式？区分方式？

1. 实现方式：通过继承Thread类实现一个线程通过实现Runnable接口实现一个线程继承的扩展性不强，Java总是支持单继承，如果一个类继承Th

叁歲伎倆/ 2023年02月23日 12:21/ 0 赞/ 42 阅读

相关 Dao层的实现——Mybatis框架3种使用方式（传统方式，代理方式，注解方式）

一.准备 ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0

阳光穿透心脏的1/2处/ 2022年11月02日 13:25/ 0 赞/ 283 阅读

相关 dubbo——广播方式和zoomkeeper方式

项目结构可以这样： parent：统一管理jar包版本号 common：常用工具类和base类 model：每个m

- 日理万妓/ 2022年06月09日 02:13/ 0 赞/ 303 阅读

相关付款方式

针对[http://blog.csdn.net/andamajing/article/details/8596546][http_blog.csdn.net_andamajin

Bertha 。/ 2022年03月30日 18:56/ 0 赞/ 396 阅读

相关 Distcp方式

转载：[https://blog.csdn.net/yinansheng1/article/details/78402459][https_blog.csdn.net_yina

超、凢脫俗/ 2022年02月19日 06:09/ 0 赞/ 345 阅读

相关快捷方式

Linux基本的键盘输入快捷键和一些常用命令 <Ctrl><Alt><F1> 切换到第一个文本终端。在Linux下你可以有多达六个不同的终端。这个命令的意思是：“同

淡淡的烟草味﹌/ 2022年01月16日 15:13/ 0 赞/ 511 阅读

相关 get方式和post方式的区别

一、get方式请求信息会显示在地址栏上（当请求信息过大时会报错）post方式不会在地址栏显示请求信息二、文件上传操作一定是post post方式和get方式的设置

深藏阁楼爱情的钟/ 2021年11月12日 00:22/ 0 赞/ 514 阅读