org.gridgain.grid.cache.compress

Class GzipCompressionStrategy

java.lang.Object

org.gridgain.grid.cache.compress.GzipCompressionStrategy

All Implemented Interfaces:

AutoCloseable, org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

public class GzipCompressionStrategy
extends Object
implements org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Gzip-based implementation of EntryCompressionStrategy.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MIN_DELTA_BYTES

Constructor Summary

Constructors

Constructor and Description
GzipCompressionStrategy(GzipCompressionConfiguration cfg)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	compressKeys() Gets flag indicating whether cache keys will be considered for compression.
byte[]	decompress(byte[] bytes) Decompresses an array of previously compressed cache data.
void	start(org.apache.ignite.internal.GridKernalContext ctx, CacheConfiguration ccfg) Initializes entry compression strategy.
boolean	stateless() Gets flag indicating whether this strategy is stateless.
byte[]	tryCompress(byte[] bytes) Tries to compress cache key or value data, as array of bytes.

Methods inherited from class java.lang.Object

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

Field Detail

MIN_DELTA_BYTES

public static final int MIN_DELTA_BYTES

See Also:

Constant Field Values

Constructor Detail

GzipCompressionStrategy

public GzipCompressionStrategy(GzipCompressionConfiguration cfg)

Method Detail

tryCompress

public byte[] tryCompress(byte[] bytes)

Tries to compress cache key or value data, as array of bytes. If successful, returns compressed array, else null.

Specified by:

tryCompress in interface org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Parameters:

bytes - Array of uncompressed data.

Returns:

Array of compressed data, or null.

decompress

public byte[] decompress(byte[] bytes)

Decompresses an array of previously compressed cache data.

Specified by:

decompress in interface org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Parameters:

bytes - Array of compressed data.

Returns:

Array of original data,.

compressKeys

public boolean compressKeys()

Gets flag indicating whether cache keys will be considered for compression.

Specified by:

compressKeys in interface org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Returns:

True if cache keys may be compressed.

stateless

public boolean stateless()

Gets flag indicating whether this strategy is stateless. Only stateless strategies may be used with snapshots. Strategies which require storing local dictionaries are not stateless.

Specified by:

stateless in interface org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Returns:

True if strategy is stateless.

start

public void start(org.apache.ignite.internal.GridKernalContext ctx,
                  CacheConfiguration ccfg)

Initializes entry compression strategy.

Specified by:

start in interface org.apache.ignite.internal.processors.cache.compress.EntryCompressionStrategy

Parameters:

ctx - Kernal context.

ccfg - Cache configuration.

close

public void close()

Specified by:

close in interface AutoCloseable