Uses of Interface
org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator
-
-
Uses of BulkFormat.RecordIterator in org.apache.flink.connector.file.src.impl
Methods in org.apache.flink.connector.file.src.impl that return BulkFormat.RecordIterator Modifier and Type Method Description BulkFormat.RecordIterator<T>StreamFormatAdapter.Reader. readBatch()Methods in org.apache.flink.connector.file.src.impl with parameters of type BulkFormat.RecordIterator Modifier and Type Method Description static <T> FileRecords<T>FileRecords. forRecords(String splitId, BulkFormat.RecordIterator<T> recordsForSplit) -
Uses of BulkFormat.RecordIterator in org.apache.flink.connector.file.src.reader
Methods in org.apache.flink.connector.file.src.reader that return BulkFormat.RecordIterator Modifier and Type Method Description BulkFormat.RecordIterator<T>BulkFormat.Reader. readBatch()Reads one batch. -
Uses of BulkFormat.RecordIterator in org.apache.flink.connector.file.src.util
Classes in org.apache.flink.connector.file.src.util that implement BulkFormat.RecordIterator Modifier and Type Class Description classArrayResultIterator<E>A simpleBulkFormat.RecordIteratorthat returns the elements of an array, one after the other.classIteratorResultIterator<E>A simpleBulkFormat.RecordIteratorthat returns the elements of an iterator, augmented with position information.classRecordMapperWrapperRecordIterator<I,O>Implementation ofBulkFormat.RecordIteratorthat wraps another iterator and performs the mapping of the records.classRecyclableIterator<E>Utility base class for iterators that accept a recycler.classSingletonResultIterator<E>A simpleBulkFormat.RecordIteratorthat returns a single value.Constructors in org.apache.flink.connector.file.src.util with parameters of type BulkFormat.RecordIterator Constructor Description RecordMapperWrapperRecordIterator(BulkFormat.RecordIterator<I> wrapped, RecordMapperWrapperRecordIterator.RecordMapper<I,O> mapper) -
Uses of BulkFormat.RecordIterator in org.apache.flink.connector.file.table
Classes in org.apache.flink.connector.file.table that implement BulkFormat.RecordIterator Modifier and Type Class Description classColumnarRowIteratorABulkFormat.RecordIteratorthat returnsRowDatas.
-