org.apache.ignite.cache.eviction.igfs

Class CacheIgfsPerBlockLruEvictionPolicy

java.lang.Object

org.apache.ignite.cache.eviction.igfs.CacheIgfsPerBlockLruEvictionPolicy

All Implemented Interfaces:

CacheEvictionPolicy<IgfsBlockKey,byte[]>, CacheIgfsPerBlockLruEvictionPolicyMXBean

public class CacheIgfsPerBlockLruEvictionPolicy
extends Object
implements CacheEvictionPolicy<IgfsBlockKey,byte[]>, CacheIgfsPerBlockLruEvictionPolicyMXBean

IGFS eviction policy which evicts particular blocks.

Constructor Summary

Constructors

Constructor and Description
CacheIgfsPerBlockLruEvictionPolicy() Default constructor.
CacheIgfsPerBlockLruEvictionPolicy(long maxSize, int maxBlocks) Constructor.
CacheIgfsPerBlockLruEvictionPolicy(long maxSize, int maxBlocks, Collection<String> excludePaths) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	exclude(IgfsPath path) Check whether provided path must be excluded from evictions.
int	getCurrentBlocks() Gets current amount of blocks.
long	getCurrentSize() Gets current size of data in all blocks.
Collection<String>	getExcludePaths() Gets collection of regex for paths whose blocks must not be evicted.
int	getMaxBlocks() Gets maximum allowed amount of blocks.
long	getMaxSize() Gets maximum allowed size of all blocks in bytes.
void	onEntryAccessed(boolean rmv, EvictableEntry<IgfsBlockKey,byte[]> entry) Callback for whenever entry is accessed.
void	setExcludePaths(Collection<String> excludePaths) Sets collection of regex for paths whose blocks must not be evicted.
void	setMaxBlocks(int maxBlocks) Sets maximum allowed amount of blocks.
void	setMaxSize(long maxSize) Sets maximum allowed size of data in all blocks in bytes.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheIgfsPerBlockLruEvictionPolicy

public CacheIgfsPerBlockLruEvictionPolicy()

Default constructor.

CacheIgfsPerBlockLruEvictionPolicy

public CacheIgfsPerBlockLruEvictionPolicy(long maxSize,
                                  int maxBlocks)

Constructor.

Parameters:

maxSize - Maximum size. When reached, eviction begins.

maxBlocks - Maximum amount of blocks. When reached, eviction begins.

CacheIgfsPerBlockLruEvictionPolicy

public CacheIgfsPerBlockLruEvictionPolicy(long maxSize,
                                  int maxBlocks,
                                  @Nullable
                                  Collection<String> excludePaths)

Constructor.

Parameters:

maxSize - Maximum size. When reached, eviction begins.

maxBlocks - Maximum amount of blocks. When reached, eviction begins.

excludePaths - Collection of regex for path which must not be evicted.

Method Detail

onEntryAccessed

public void onEntryAccessed(boolean rmv,
                   EvictableEntry<IgfsBlockKey,byte[]> entry)

Callback for whenever entry is accessed.

Specified by:

onEntryAccessed in interface CacheEvictionPolicy<IgfsBlockKey,byte[]>

Parameters:

rmv - True if entry has been removed, false otherwise.

entry - Accessed entry.

getMaxSize

public long getMaxSize()

Gets maximum allowed size of all blocks in bytes.

Specified by:

getMaxSize in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Returns:

Maximum allowed size of all blocks in bytes.

setMaxSize

public void setMaxSize(long maxSize)

Sets maximum allowed size of data in all blocks in bytes.

Specified by:

setMaxSize in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Parameters:

maxSize - Maximum allowed size of data in all blocks in bytes.

getMaxBlocks

public int getMaxBlocks()

Gets maximum allowed amount of blocks.

Specified by:

getMaxBlocks in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Returns:

Maximum allowed amount of blocks.

setMaxBlocks

public void setMaxBlocks(int maxBlocks)

Sets maximum allowed amount of blocks.

Specified by:

setMaxBlocks in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Parameters:

maxBlocks - Maximum allowed amount of blocks.

getExcludePaths

public Collection<String> getExcludePaths()

Gets collection of regex for paths whose blocks must not be evicted.

Specified by:

getExcludePaths in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Returns:

Collection of regex for paths whose blocks must not be evicted.

setExcludePaths

public void setExcludePaths(@Nullable
                   Collection<String> excludePaths)

Sets collection of regex for paths whose blocks must not be evicted.

Specified by:

setExcludePaths in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Parameters:

excludePaths - Collection of regex for paths whose blocks must not be evicted.

getCurrentSize

public long getCurrentSize()

Gets current size of data in all blocks.

Specified by:

getCurrentSize in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Returns:

Current size of data in all blocks.

getCurrentBlocks

public int getCurrentBlocks()

Gets current amount of blocks.

Specified by:

getCurrentBlocks in interface CacheIgfsPerBlockLruEvictionPolicyMXBean

Returns:

Current amount of blocks.

exclude

public boolean exclude(IgfsPath path)
                throws IgniteCheckedException

Check whether provided path must be excluded from evictions.

Parameters:

path - Path.

Returns:

True in case non block of related file must be excluded.

Throws:

IgniteCheckedException - In case of faulty patterns.