org.gridgain.grid.kernal.processors.cache

Class GridCacheSwapManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheSwapManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheSwapManager<K,V>
extends GridCacheManagerAdapter<K,V>

Handles all swap operations.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheSwapManager(boolean enabled)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOffHeapListener(int part, GridCacheSwapListener<K,V> lsnr)
void	addSwapListener(int part, GridCacheSwapListener<K,V> lsnr)
void	clearOffHeap() Clears off-heap.
void	clearSwap() Clears swap.
boolean	containsKey(K key, byte[] keyBytes)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	iterator(int part) Gets offheap and swap iterator over partition.
Iterator<Map.Entry<K,V>>	lazyOffHeapIterator()
Iterator<Map.Entry<K,V>>	lazySwapIterator()
long	offHeapAllocatedSize() Gets memory size allocated in off-heap.
boolean	offHeapEnabled()
long	offHeapEntriesCount() Gets number of elements in off-heap
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	offHeapIterator(int part) Gets offheap iterator over partition.
int	onUndeploy(UUID leftNodeId, ClassLoader ldr)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawIterator() Gets offheap and swap iterator over partition.
Collection<GridCacheBatchSwapEntry<K,V>>	readAndRemove(Collection<? extends K> keys)
void	removeOffHeapListener(int part, GridCacheSwapListener<K,V> lsnr)
void	removeSwapListener(int part, GridCacheSwapListener<K,V> lsnr)
void	start0()
boolean	swapEnabled()
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	swapIterator(int part) Gets swap space iterator over partition.
long	swapKeys() Gets number of swap entries (keys).
long	swapSize()

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, printMemoryStats, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheSwapManager

public GridCacheSwapManager(boolean enabled)

Parameters:

enabled - Flag to indicate if swap is enabled.

Method Detail

start0

public void start0()
            throws GridException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

swapEnabled

public boolean swapEnabled()

Returns:

True if swap store is enabled.

offHeapEnabled

public boolean offHeapEnabled()

Returns:

True if off-heap cache is enabled.

swapSize

public long swapSize()
              throws GridException

Returns:

Swap size.

Throws:

GridException - If failed.

swapKeys

public long swapKeys()
              throws GridException

Gets number of swap entries (keys).

Returns:

Swap keys count.

Throws:

GridException - If failed.

addSwapListener

public void addSwapListener(int part,
                   GridCacheSwapListener<K,V> lsnr)

Parameters:

part - Partition.

lsnr - Listener.

removeSwapListener

public void removeSwapListener(int part,
                      GridCacheSwapListener<K,V> lsnr)

Parameters:

part - Partition.

lsnr - Listener.

addOffHeapListener

public void addOffHeapListener(int part,
                      GridCacheSwapListener<K,V> lsnr)

Parameters:

part - Partition.

lsnr - Listener.

removeOffHeapListener

public void removeOffHeapListener(int part,
                         GridCacheSwapListener<K,V> lsnr)

Parameters:

part - Partition.

lsnr - Listener.

containsKey

public boolean containsKey(K key,
                  byte[] keyBytes)
                    throws GridException

Parameters:

key - Key to check.

keyBytes - Key bytes to check.

Returns:

True if key is contained.

Throws:

GridException - If failed.

readAndRemove

public Collection<GridCacheBatchSwapEntry<K,V>> readAndRemove(Collection<? extends K> keys)
                                                       throws GridException

Parameters:

keys - Collection of keys to remove from swap.

Returns:

Collection of swap entries.

Throws:

GridException - If failed,

clearOffHeap

public void clearOffHeap()

Clears off-heap.

clearSwap

public void clearSwap()
               throws GridException

Clears swap.

Throws:

GridException - If failed.

iterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> iterator(int part)
                                                                        throws GridException

Gets offheap and swap iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

GridException - If failed.

rawIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawIterator()
                                                            throws GridException

Gets offheap and swap iterator over partition.

Returns:

Iterator over partition.

Throws:

GridException - If failed.

lazySwapIterator

public Iterator<Map.Entry<K,V>> lazySwapIterator()
                                          throws GridException

Returns:

Lazy swap iterator.

Throws:

GridException - If failed.

lazyOffHeapIterator

public Iterator<Map.Entry<K,V>> lazyOffHeapIterator()

Returns:

Lazy off-heap iterator.

offHeapEntriesCount

public long offHeapEntriesCount()

Gets number of elements in off-heap

Returns:

Number of elements or 0 if off-heap is disabled.

offHeapAllocatedSize

public long offHeapAllocatedSize()

Gets memory size allocated in off-heap.

Returns:

Allocated memory size or 0 if off-heap is disabled.

offHeapIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> offHeapIterator(int part)
                                                                               throws GridException

Gets offheap iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

GridException - If failed.

swapIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>> swapIterator(int part)
                                                                            throws GridException

Gets swap space iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

GridException - If failed.

onUndeploy

public int onUndeploy(UUID leftNodeId,
             ClassLoader ldr)

Parameters:

leftNodeId - Left Node ID.

ldr - Undeployed class loader.

Returns:

Undeploy count.