Package org.apache.iceberg.flink.source.reader

Interface RowDataConverter<T>

Type Parameters:

T - output type

All Superinterfaces:

java.util.function.Function<org.apache.flink.table.data.RowData,T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, java.io.Serializable

All Known Implementing Classes:

AvroGenericRecordConverter

public interface RowDataConverter<T>
extends java.util.function.Function<org.apache.flink.table.data.RowData,T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, java.io.Serializable

Convert RowData to a different output type.

Method Summary

Methods inherited from interface java.util.function.Function

andThen, apply, compose

Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

getProducedType