Package org.apache.iceberg.flink.sink
package org.apache.iceberg.flink.sink
-
ClassDescriptionThis util class converts Avro GenericRecord to Flink RowData.Create a
KeySelectorto shuffle by equality fields, to ensure same equality fields record will be emitted to same writer in order.This serializer is used for serializing theIcebergCommittableobjects between the Writer and the Aggregator operator and between the Aggregator and the Committer as well.Flink v2 sink offer different hooks to insert custom topologies into the sink.Create aKeySelectorto shuffle by partition key, then each partition/bucket will be wrote by only one task.Factory to createTaskWriter