Package org.apache.iceberg.flink.sink
-
Interface Summary Interface Description TaskWriterFactory<T> Factory to createTaskWriter -
Class Summary Class Description AvroGenericRecordToRowDataMapper This util class converts Avro GenericRecord to Flink RowData.FlinkAppenderFactory FlinkSink FlinkSink.Builder FlinkWriteResult IcebergSink Flink v2 sink offer different hooks to insert custom topologies into the sink.IcebergSink.Builder RowDataTaskWriterFactory