Package com.linkedin.venice.compression

Class CompressorFactory

java.lang.Object

com.linkedin.venice.compression.CompressorFactory

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

StorageEngineBackedCompressorFactory

public class CompressorFactory
extends Object
implements Closeable, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
CompressorFactory()

Method Summary

Modifier and Type	Method	Description
void	close()
VeniceCompressor	createCompressorWithDictionary(byte[] dictionary, int level)
VeniceCompressor	createVersionSpecificCompressorIfNotExist(CompressionStrategy compressionStrategy, String kafkaTopic, byte[] dictionary)
VeniceCompressor	createVersionSpecificCompressorIfNotExist(CompressionStrategy compressionStrategy, String kafkaTopic, byte[] dictionary, int compressionLevel)
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy)
VeniceCompressor	getVersionSpecificCompressor(String kafkaTopic)
void	removeVersionSpecificCompressor(String kafkaTopic)
boolean	versionSpecificCompressorExists(String kafkaTopic)

Methods inherited from class java.lang.Object

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

Constructor Details

CompressorFactory

public CompressorFactory()

Method Details

getCompressor

public VeniceCompressor getCompressor(CompressionStrategy compressionStrategy)

createVersionSpecificCompressorIfNotExist

public VeniceCompressor createVersionSpecificCompressorIfNotExist(CompressionStrategy compressionStrategy,
 String kafkaTopic,
 byte[] dictionary)

createVersionSpecificCompressorIfNotExist

public VeniceCompressor createVersionSpecificCompressorIfNotExist(CompressionStrategy compressionStrategy,
 String kafkaTopic,
 byte[] dictionary,
 int compressionLevel)

getVersionSpecificCompressor

public VeniceCompressor getVersionSpecificCompressor(String kafkaTopic)

removeVersionSpecificCompressor

public void removeVersionSpecificCompressor(String kafkaTopic)

versionSpecificCompressorExists

public boolean versionSpecificCompressorExists(String kafkaTopic)

createCompressorWithDictionary

public VeniceCompressor createCompressorWithDictionary(byte[] dictionary,
 int level)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable