RecordWiseFileCompactor.Reader.Factory (Flink : Connectors : Files 2.2.0 API)

Type Parameters:

T - Thy type of the records that is read.

All Superinterfaces:

Serializable

All Known Implementing Classes:

DecoderBasedReader.Factory, InputFormatBasedReader.Factory

Enclosing interface:

RecordWiseFileCompactor.Reader<T>
```
public static interface RecordWiseFileCompactor.Reader.Factory<T>
extends Serializable
```
Factory for RecordWiseFileCompactor.Reader.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  RecordWiseFileCompactor.Reader<T> createFor(org.apache.flink.core.fs.Path path)

- Method Detail
  - createFor
```
RecordWiseFileCompactor.Reader<T> createFor(org.apache.flink.core.fs.Path path)
                                     throws IOException
```
    Returns:
    
    A reader that reads elements from the given file.
    
    Throws:
    
    IOException - Thrown if an I/O error occurs when opening the file.