Uses of Interface
org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Decoder
-
Packages that use DecoderBasedReader.Decoder Package Description org.apache.flink.connector.file.sink.compactor -
-
Uses of DecoderBasedReader.Decoder in org.apache.flink.connector.file.sink.compactor
Classes in org.apache.flink.connector.file.sink.compactor that implement DecoderBasedReader.Decoder Modifier and Type Class Description classSimpleStringDecoderA sinkDecoderBasedReader.Decoderthat reads data encoded by theSimpleStringEncoderonly for compaction.Methods in org.apache.flink.connector.file.sink.compactor that return DecoderBasedReader.Decoder Modifier and Type Method Description DecoderBasedReader.Decoder<T>DecoderBasedReader.Decoder.Factory. create()Constructors in org.apache.flink.connector.file.sink.compactor with parameters of type DecoderBasedReader.Decoder Constructor Description DecoderBasedReader(org.apache.flink.core.fs.Path path, DecoderBasedReader.Decoder<T> decoder)
-