Uses of Interface
org.apache.flink.connector.file.src.util.RecordMapperWrapperRecordIterator.RecordMapper
-
Packages that use RecordMapperWrapperRecordIterator.RecordMapper Package Description org.apache.flink.connector.file.src.util -
-
Uses of RecordMapperWrapperRecordIterator.RecordMapper in org.apache.flink.connector.file.src.util
Methods in org.apache.flink.connector.file.src.util with parameters of type RecordMapperWrapperRecordIterator.RecordMapper Modifier and Type Method Description static <I,O>
BulkFormat.Reader<O>RecordMapperWrapperRecordIterator. wrapReader(BulkFormat.Reader<I> wrappedReader, RecordMapperWrapperRecordIterator.RecordMapper<I,O> recordMapper)Wrap aBulkFormat.Readerapplying aRecordMapperWrapperRecordIterator.RecordMapperon the returned iterator.Constructors in org.apache.flink.connector.file.src.util with parameters of type RecordMapperWrapperRecordIterator.RecordMapper Constructor Description RecordMapperWrapperRecordIterator(BulkFormat.RecordIterator<I> wrapped, RecordMapperWrapperRecordIterator.RecordMapper<I,O> mapper)
-