CompactBulkReader (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.connector.file.table.stream.compact.CompactBulkReader<T>

All Implemented Interfaces:

Closeable, AutoCloseable, CompactReader<T>
```
@Internal
public class CompactBulkReader<T>
extends Object
implements CompactReader<T>
```
The CompactReader to delegate CompactBulkReader.

Constructor Summary

Constructors
Constructor Description

CompactBulkReader(BulkFormat.Reader<T> reader)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`static <T> CompactReader.Factory<T>`	`factory(BulkFormat<T,FileSourceSplit> format)`
`T`	`read()`	Read a record, return null if no more record.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - CompactBulkReader
```
public CompactBulkReader(BulkFormat.Reader<T> reader)
                  throws IOException
```
    Throws:
    
    IOException
- 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 interface CompactReader<T>
    
    Throws:
    
    IOException
  - close
```
public void close()
           throws IOException
```
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface Closeable
    
    Throws:
    
    IOException
  - factory
```
public static <T> CompactReader.Factory<T> factory(BulkFormat<T,FileSourceSplit> format)
```