Package org.apache.ignite.internal.processors.compress

Class CompressionProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.compress.CompressionProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class CompressionProcessor
extends GridProcessorAdapter

Compression processor.

See Also:

IgniteComponentType.COMPRESSION

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field	Description
protected static byte	COMPACTED_PAGE
protected static byte	LZ4_COMPRESSED_PAGE
static int	LZ4_DEFAULT_LEVEL
static int	LZ4_MAX_LEVEL
static int	LZ4_MIN_LEVEL
protected static byte	SNAPPY_COMPRESSED_PAGE
static byte	UNCOMPRESSED_PAGE
protected static byte	ZSTD_COMPRESSED_PAGE
static int	ZSTD_DEFAULT_LEVEL
static int	ZSTD_MAX_LEVEL
static int	ZSTD_MIN_LEVEL

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
CompressionProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
static int	checkCompressionLevelBounds(int compressLevel, DiskPageCompression compression)
void	checkPageCompressionSupported()	Checks weither page compression can be used for page file storage.
void	checkPageCompressionSupported(Path storagePath, int pageSize)	Checks weither page file storage supports compression.
ByteBuffer	compressPage(ByteBuffer page, int pageSize, int blockSize, DiskPageCompression compression, int compressLevel)
void	decompressPage(ByteBuffer page, int pageSize)
protected ByteBuffer	doCompactPage(ByteBuffer page, int pageSize)
protected ByteBuffer	doCompressPage(DiskPageCompression compression, ByteBuffer compactPage, int compactSize, int compressLevel)
protected void	doDecompressPage(int compressType, ByteBuffer page, int compressedSize, int compactSize)
static int	getCompressionLevel(Integer compressLevel, DiskPageCompression compression)
static int	getDefaultCompressionLevel(DiskPageCompression compression)
protected static ByteBuffer	setCompactionInfo(ByteBuffer page, int compactSize)
protected static ByteBuffer	setCompressionInfo(ByteBuffer page, DiskPageCompression compression, int compressedSize, int compactedSize)

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Field Detail

LZ4_MIN_LEVEL

public static final int LZ4_MIN_LEVEL

See Also:

Constant Field Values

LZ4_MAX_LEVEL

public static final int LZ4_MAX_LEVEL

See Also:

Constant Field Values

LZ4_DEFAULT_LEVEL

public static final int LZ4_DEFAULT_LEVEL

See Also:

Constant Field Values

ZSTD_MIN_LEVEL

public static final int ZSTD_MIN_LEVEL

See Also:

Constant Field Values

ZSTD_MAX_LEVEL

public static final int ZSTD_MAX_LEVEL

See Also:

Constant Field Values

ZSTD_DEFAULT_LEVEL

public static final int ZSTD_DEFAULT_LEVEL

See Also:

Constant Field Values

UNCOMPRESSED_PAGE

public static final byte UNCOMPRESSED_PAGE

See Also:

Constant Field Values

COMPACTED_PAGE

protected static final byte COMPACTED_PAGE

See Also:

Constant Field Values

ZSTD_COMPRESSED_PAGE

protected static final byte ZSTD_COMPRESSED_PAGE

See Also:

Constant Field Values

LZ4_COMPRESSED_PAGE

protected static final byte LZ4_COMPRESSED_PAGE

See Also:

Constant Field Values

SNAPPY_COMPRESSED_PAGE

protected static final byte SNAPPY_COMPRESSED_PAGE

See Also:

Constant Field Values

Constructor Detail

CompressionProcessor

public CompressionProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

getCompressionLevel

public static int getCompressionLevel(Integer compressLevel,
                                      DiskPageCompression compression)

Parameters:

compressLevel - Compression level.

compression - Compression algorithm.

Returns:

Compression level.

getDefaultCompressionLevel

public static int getDefaultCompressionLevel(DiskPageCompression compression)

Parameters:

compression - Compression algorithm.

Returns:

Default compression level.

checkCompressionLevelBounds

public static int checkCompressionLevelBounds(int compressLevel,
                                              DiskPageCompression compression)

Parameters:

compressLevel - Compression level.

compression - Compression algorithm.

Returns:

Compression level.

checkPageCompressionSupported

public void checkPageCompressionSupported()
                                   throws IgniteCheckedException

Checks weither page compression can be used for page file storage.

Throws:

IgniteCheckedException - If compression is not supported.

checkPageCompressionSupported

public void checkPageCompressionSupported(Path storagePath,
                                          int pageSize)
                                   throws IgniteCheckedException

Checks weither page file storage supports compression.

Parameters:

storagePath - Storage path.

pageSize - Page size.

Throws:

IgniteCheckedException - If compression is not supported.

setCompactionInfo

protected static ByteBuffer setCompactionInfo(ByteBuffer page,
                                              int compactSize)

Parameters:

page - Page.

compactSize - Compacted page size.

Returns:

The given page.

setCompressionInfo

protected static ByteBuffer setCompressionInfo(ByteBuffer page,
                                               DiskPageCompression compression,
                                               int compressedSize,
                                               int compactedSize)

Parameters:

page - Page.

compression - Compression algorithm.

compressedSize - Compressed size.

compactedSize - Compact size.

Returns:

The given page.

compressPage

public ByteBuffer compressPage(ByteBuffer page,
                               int pageSize,
                               int blockSize,
                               DiskPageCompression compression,
                               int compressLevel)
                        throws IgniteCheckedException

Parameters:

page - Page buffer.

pageSize - Page size.

blockSize - Store block size.

compression - Compression algorithm.

compressLevel - Compression level.

Returns:

Possibly compressed buffer.

Throws:

IgniteCheckedException - If failed.

doCompactPage

protected ByteBuffer doCompactPage(ByteBuffer page,
                                   int pageSize)
                            throws IgniteCheckedException

Parameters:

page - Page buffer.

pageSize - Page size.

Returns:

Compacted page buffer.

Throws:

IgniteCheckedException

doCompressPage

protected ByteBuffer doCompressPage(DiskPageCompression compression,
                                    ByteBuffer compactPage,
                                    int compactSize,
                                    int compressLevel)

Parameters:

compression - Compression algorithm.

compactPage - Compacted page.

compactSize - Compacted page size.

compressLevel - Compression level.

Returns:

Compressed page.

decompressPage

public void decompressPage(ByteBuffer page,
                           int pageSize)
                    throws IgniteCheckedException

Parameters:

page - Possibly compressed page buffer.

pageSize - Page size.

Throws:

IgniteCheckedException - If failed.

doDecompressPage

protected void doDecompressPage(int compressType,
                                ByteBuffer page,
                                int compressedSize,
                                int compactSize)