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>
TheCompactReader
to delegateFileInputFormat
.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
static <T> CompactReader.Factory<T>
factory(FileInputFormat<T> format)
T
read()
Read a record, return null if no more record.
-
-
-
Method Detail
-
read
public T read() throws IOException
Description copied from interface:CompactReader
Read a record, return null if no more record.- Specified by:
read
in interfaceCompactReader<T>
- Throws:
IOException
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
factory
public static <T> CompactReader.Factory<T> factory(FileInputFormat<T> format)
-
-