Package com.linkedin.davinci.compression

Class StorageEngineBackedCompressorFactory

java.lang.Object

com.linkedin.venice.compression.CompressorFactory

com.linkedin.davinci.compression.StorageEngineBackedCompressorFactory

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class StorageEngineBackedCompressorFactory
extends CompressorFactory

Constructor Summary

Constructors

Constructor	Description
StorageEngineBackedCompressorFactory(StorageMetadataService metadataService)

Method Summary

Modifier and Type	Method	Description
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy, java.lang.String kafkaTopic, int dictCompressionLevel)

Methods inherited from class com.linkedin.venice.compression.CompressorFactory

close, createCompressorWithDictionary, createVersionSpecificCompressorIfNotExist, createVersionSpecificCompressorIfNotExist, getCompressor, getVersionSpecificCompressor, removeVersionSpecificCompressor, versionSpecificCompressorExists

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StorageEngineBackedCompressorFactory

public StorageEngineBackedCompressorFactory(StorageMetadataService metadataService)

Method Detail

getCompressor

public VeniceCompressor getCompressor(CompressionStrategy compressionStrategy,
                                      java.lang.String kafkaTopic,
                                      int dictCompressionLevel)