Package org.apache.iceberg.flink.sink
package org.apache.iceberg.flink.sink
-
ClassDescriptionThis util class converts Avro GenericRecord to Flink RowData.Flink v2 sink offer different hooks to insert custom topologies into the sink.Factory to create
TaskWriter