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.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.