Class FileInputFormatCompactReader<T>
- java.lang.Object
-
- org.apache.flink.connector.file.table.stream.compact.FileInputFormatCompactReader<T>
-
- All Implemented Interfaces:
Closeable,AutoCloseable,CompactReader<T>
@Internal public class FileInputFormatCompactReader<T> extends Object implements CompactReader<T>
TheCompactReaderto delegateFileInputFormat.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()static <T> CompactReader.Factory<T>factory(org.apache.flink.api.common.io.FileInputFormat<T> format)Tread()Read a record, return null if no more record.
-
-
-
Method Detail
-
read
public T read() throws IOException
Description copied from interface:CompactReaderRead a record, return null if no more record.- Specified by:
readin interfaceCompactReader<T>- Throws:
IOException
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
factory
public static <T> CompactReader.Factory<T> factory(org.apache.flink.api.common.io.FileInputFormat<T> format)
-
-