Package org.apache.cassandra.schema

Class CompressionParams

java.lang.Object

org.apache.cassandra.schema.CompressionParams

public final class CompressionParams
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHUNK_LENGTH_IN_KB
static final String	CLASS
static final CompressionParams	DEFAULT
static final int	DEFAULT_CHUNK_LENGTH
static final double	DEFAULT_MIN_COMPRESS_RATIO
static final String	ENABLED
static final String	MIN_COMPRESS_RATIO
static final CompressionParams	NOOP
static final IVersionedSerializer<CompressionParams>	serializer

Constructor Summary

Constructors

Constructor	Description
CompressionParams(String sstableCompressorClass, int chunkLength, int maxCompressedLength, Map<String,String> otherOptions)
CompressionParams(String sstableCompressorClass, Map<String,String> otherOptions, int chunkLength, double minCompressRatio)

Method Summary

Modifier and Type	Method	Description
Map<String,String>	asMap()
int	chunkLength()
String	chunkLengthInKB()
CompressionParams	copy()
static ICompressor	createCompressor(ParameterizedClass compression)
static CompressionParams	deflate()
static CompressionParams	deflate(int chunkLength)
boolean	equals(Object obj)
static CompressionParams	fromMap(Map<String,String> opts)
com.google.common.collect.ImmutableMap<String,String>	getOtherOptions()
ICompressor	getSstableCompressor()	Returns the SSTable compressor.
int	hashCode()
boolean	isEnabled()	Checks if compression is enabled.
static boolean	isEnabled(Map<String,String> options)	Returns true if the options contains the enabled option and that its value is true, otherwise returns false.
Class<? extends ICompressor>	klass()
static CompressionParams	lz4()
static CompressionParams	lz4(int chunkLength)
static CompressionParams	lz4(int chunkLength, int maxCompressedLength)
int	maxCompressedLength()
static CompressionParams	noCompression()
static CompressionParams	noop()
static CompressionParams	snappy()
static CompressionParams	snappy(int chunkLength)
static CompressionParams	snappy(int chunkLength, double minCompressRatio)
void	validate()
static CompressionParams	zstd()
static CompressionParams	zstd(Integer chunkLength)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_CHUNK_LENGTH

public static final int DEFAULT_CHUNK_LENGTH

See Also:

• Constant Field Values

DEFAULT_MIN_COMPRESS_RATIO

public static final double DEFAULT_MIN_COMPRESS_RATIO

See Also:

• Constant Field Values

serializer

public static final IVersionedSerializer<CompressionParams> serializer

CLASS

public static final String CLASS

See Also:

• Constant Field Values

CHUNK_LENGTH_IN_KB

public static final String CHUNK_LENGTH_IN_KB

See Also:

• Constant Field Values

ENABLED

public static final String ENABLED

See Also:

• Constant Field Values

MIN_COMPRESS_RATIO

public static final String MIN_COMPRESS_RATIO

See Also:

• Constant Field Values

DEFAULT

public static final CompressionParams DEFAULT

NOOP

public static final CompressionParams NOOP

Constructor Details

CompressionParams

public CompressionParams(String sstableCompressorClass,
 Map<String,String> otherOptions,
 int chunkLength,
 double minCompressRatio)
                  throws ConfigurationException

Throws:

ConfigurationException

CompressionParams

public CompressionParams(String sstableCompressorClass,
 int chunkLength,
 int maxCompressedLength,
 Map<String,String> otherOptions)
                  throws ConfigurationException

Throws:

ConfigurationException

Method Details

fromMap

public static CompressionParams fromMap(Map<String,String> opts)

klass

public Class<? extends ICompressor> klass()

noCompression

public static CompressionParams noCompression()

snappy

public static CompressionParams snappy()

snappy

public static CompressionParams snappy(int chunkLength)

snappy

public static CompressionParams snappy(int chunkLength,
 double minCompressRatio)

deflate

public static CompressionParams deflate()

deflate

public static CompressionParams deflate(int chunkLength)

lz4

public static CompressionParams lz4()

lz4

public static CompressionParams lz4(int chunkLength)

lz4

public static CompressionParams lz4(int chunkLength,
 int maxCompressedLength)

zstd

public static CompressionParams zstd()

zstd

public static CompressionParams zstd(Integer chunkLength)

noop

public static CompressionParams noop()

copy

public CompressionParams copy()

isEnabled

public boolean isEnabled()

Checks if compression is enabled.

Returns:

true if compression is enabled, false otherwise.

getSstableCompressor

public ICompressor getSstableCompressor()

Returns the SSTable compressor.

Returns:

the SSTable compressor or null if compression is disabled.

getOtherOptions

public com.google.common.collect.ImmutableMap<String,String> getOtherOptions()

chunkLength

public int chunkLength()

maxCompressedLength

public int maxCompressedLength()

createCompressor

public static ICompressor createCompressor(ParameterizedClass compression)
                                    throws ConfigurationException

Throws:

ConfigurationException

isEnabled

public static boolean isEnabled(Map<String,String> options)

Returns true if the options contains the enabled option and that its value is true, otherwise returns false.

Parameters:

options - the options

Returns:

true if the options contains the enabled option and that its value is true, otherwise returns false.

validate

public void validate()
              throws ConfigurationException

Throws:

ConfigurationException

asMap

public Map<String,String> asMap()

chunkLengthInKB

public String chunkLengthInKB()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object