【flink】RowData copy/clone方式

向右看齐 2024-02-20 12:12 3阅读 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 条评论，3人围观）

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

相关阅读

相关线程通信方式：休眠唤醒方式

/*线程之间的通信方式:方式一：使用notify+wait+object实现线程之间的通信*/ /*实例：奇数线程打印10以内的奇数，偶数线程打印10以内的...

女爷i/ 2024年04月19日 13:24/ 0 赞/ 38 阅读

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

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

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

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

一.准备 ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0

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

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

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

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

相关付款方式

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

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

相关 redis两种备份方式（持久化方式）

一、redis持久化的两种方式： RDB: 对内存中数据库状态进行快照 AOF: 把每条写命令都写入文件 RDB方式：将redis在内存中的

落日映苍穹つ/ 2022年03月17日 09:20/ 0 赞/ 1756 阅读

相关 Distcp方式

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

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

相关快捷方式

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

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

相关 http的get方式和post方式

如文：提供httpUrl的get和post方式，可以当工具类使用 package com.tcl.bill.http; import java.io

╰+攻爆jí腚メ/ 2022年01月05日 21:17/ 0 赞/ 239 阅读

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

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

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