Skip to content

Flink: move away from InternalSerializers for cloning RowData #2184

@stevenzwu

Description

@stevenzwu

Right now, Flink code needs to use InternalSerializers to clone RowData. We should just avoid using @Internal classes as Flink is free to break the compatibility in minor releases.

We can clone a RowData into a newly created GenericRowData, that means we don't have to use the complex TypeSerializer ( that is used for copying binary data for BinaryRowData).

Ideally, Flink should provide a public API of RowData#clone/deepCopy, there RowData impl classes can choose the best way of cloning objects.

Some more context is provided by @openinx
#1956 (comment)

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions