org.apache.paimon.schema

Class NestedSchemaUtils

java.lang.Object

org.apache.paimon.schema.NestedSchemaUtils

public class NestedSchemaUtils
extends Object

Utility class for handling nested column schema changes. This provides shared logic for both FlinkCatalog and CDC sources to handle schema evolution for nested types (arrays, maps, multisets, rows) consistently.

Constructor Summary

Constructors

Constructor and Description
NestedSchemaUtils()

Method Summary

Modifier and Type	Method and Description
static void	generateNestedColumnUpdates(List<String> fieldNames, DataType oldType, DataType newType, List<SchemaChange> schemaChanges) Generates nested column updates for schema evolution.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NestedSchemaUtils

public NestedSchemaUtils()

Method Detail

generateNestedColumnUpdates

public static void generateNestedColumnUpdates(List<String> fieldNames,
                                               DataType oldType,
                                               DataType newType,
                                               List<SchemaChange> schemaChanges)

Generates nested column updates for schema evolution. Handles all nested types: ROW, ARRAY, MAP, MULTISET. Creates proper field paths with markers like "element" for arrays and "value" for maps.

Parameters:

fieldNames - The current field path as a list of field names

oldType - The old data type

newType - The new data type

schemaChanges - List to collect the generated schema changes