Uses of Interface
org.apache.flink.connector.file.sink.compactor.RecordWiseFileCompactor.Reader
-
Packages that use RecordWiseFileCompactor.Reader Package Description org.apache.flink.connector.file.sink.compactor -
-
Uses of RecordWiseFileCompactor.Reader in org.apache.flink.connector.file.sink.compactor
Classes in org.apache.flink.connector.file.sink.compactor that implement RecordWiseFileCompactor.Reader Modifier and Type Class Description classDecoderBasedReader<T>ARecordWiseFileCompactor.Readerimplementation that reads the file as anFSDataInputStreamand decodes the record with theDecoderBasedReader.Decoder.classInputFormatBasedReader<T>ARecordWiseFileCompactor.Readerimplementation that reads the file using theFileInputFormat.Methods in org.apache.flink.connector.file.sink.compactor that return RecordWiseFileCompactor.Reader Modifier and Type Method Description RecordWiseFileCompactor.Reader<T>RecordWiseFileCompactor.Reader.Factory. createFor(org.apache.flink.core.fs.Path path)
-