Package org.apache.iceberg.flink.sink.dynamic
package org.apache.iceberg.flink.sink.dynamic
-
ClassDescriptionVisitor class which compares an input schema to a table schema and emits a compatibility
CompareSchemasVisitor.Result.Dynamic version of the IcebergSink which supports: Writing to any number of tables (No more 1:1 sink/topic relationship).A DynamicRecord contains RowData alongside with the Iceberg table metadata.A generator to yieldDynamicRecordfrom the provided input.Abstract base class for SQL-based dynamic record generators.Visitor class that accumulates the set of changes needed to evolve an existing schema into the target schema.Checks compatibility of PartitionSpecs and evolves one into the other.