Package | Description |
---|---|
org.apache.flink.connector.file.sink.compactor |
Modifier and Type | Class and Description |
---|---|
class |
DecoderBasedReader<T>
A
RecordWiseFileCompactor.Reader implementation that reads the file as an FSDataInputStream and decodes the record with the DecoderBasedReader.Decoder . |
class |
InputFormatBasedReader<T>
A
RecordWiseFileCompactor.Reader implementation that reads the file using the FileInputFormat . |
Modifier and Type | Method and Description |
---|---|
RecordWiseFileCompactor.Reader<T> |
RecordWiseFileCompactor.Reader.Factory.createFor(Path path) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.