Package org.apache.iceberg.flink.sink.dynamic

Class CompareSchemasVisitor

java.lang.Object

org.apache.iceberg.schema.SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

org.apache.iceberg.flink.sink.dynamic.CompareSchemasVisitor

public class CompareSchemasVisitor
extends SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

Visitor class which compares an input schema to a table schema and emits a compatibility CompareSchemasVisitor.Result.

• SAME: The two schemas are semantically identical
• DATA_CONVERSION_NEEDED: We can evolve the data associated with the input schema to match the table schema.
• SCHEMA_UPDATE_NEEDED: We need to migrate the table schema to match the input schema.

The input schema fields are compared to the table schema via their names.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CompareSchemasVisitor.Result

Nested classes/interfaces inherited from class org.apache.iceberg.schema.SchemaWithPartnerVisitor

SchemaWithPartnerVisitor.PartnerAccessors<P>

Method Summary

Modifier and Type	Method	Description
CompareSchemasVisitor.Result	field(Types.NestedField field, Integer tableSchemaId, CompareSchemasVisitor.Result typeResult)
CompareSchemasVisitor.Result	list(Types.ListType list, Integer tableSchemaId, CompareSchemasVisitor.Result elementsResult)
CompareSchemasVisitor.Result	map(Types.MapType map, Integer tableSchemaId, CompareSchemasVisitor.Result keyResult, CompareSchemasVisitor.Result valueResult)
CompareSchemasVisitor.Result	primitive(Type.PrimitiveType primitive, Integer tableSchemaId)
CompareSchemasVisitor.Result	schema(Schema dataSchema, Integer tableSchemaId, CompareSchemasVisitor.Result downstream)
CompareSchemasVisitor.Result	struct(Types.StructType struct, Integer tableSchemaId, List<CompareSchemasVisitor.Result> fields)
static CompareSchemasVisitor.Result	visit(Schema dataSchema, Schema tableSchema)
static CompareSchemasVisitor.Result	visit(Schema dataSchema, Schema tableSchema, boolean caseSensitive)

Methods inherited from class org.apache.iceberg.schema.SchemaWithPartnerVisitor

afterField, afterListElement, afterMapKey, afterMapValue, beforeField, beforeListElement, beforeMapKey, beforeMapValue, variant, visit, visit

Methods inherited from class java.lang.Object

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

Method Details

visit

public static CompareSchemasVisitor.Result visit(Schema dataSchema,
 Schema tableSchema)

visit

public static CompareSchemasVisitor.Result visit(Schema dataSchema,
 Schema tableSchema,
 boolean caseSensitive)

schema

public CompareSchemasVisitor.Result schema(Schema dataSchema,
 Integer tableSchemaId,
 CompareSchemasVisitor.Result downstream)

Overrides:

schema in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

struct

public CompareSchemasVisitor.Result struct(Types.StructType struct,
 Integer tableSchemaId,
 List<CompareSchemasVisitor.Result> fields)

Overrides:

struct in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

field

public CompareSchemasVisitor.Result field(Types.NestedField field,
 Integer tableSchemaId,
 CompareSchemasVisitor.Result typeResult)

Overrides:

field in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

list

public CompareSchemasVisitor.Result list(Types.ListType list,
 Integer tableSchemaId,
 CompareSchemasVisitor.Result elementsResult)

Overrides:

list in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

map

public CompareSchemasVisitor.Result map(Types.MapType map,
 Integer tableSchemaId,
 CompareSchemasVisitor.Result keyResult,
 CompareSchemasVisitor.Result valueResult)

Overrides:

map in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>

primitive

public CompareSchemasVisitor.Result primitive(Type.PrimitiveType primitive,
 Integer tableSchemaId)

Overrides:

primitive in class SchemaWithPartnerVisitor<Integer,CompareSchemasVisitor.Result>