org.apache.ignite.internal.processors.cache.warmup

Class LoadAllWarmUpStrategy

java.lang.Object

org.apache.ignite.internal.processors.cache.warmup.LoadAllWarmUpStrategy

All Implemented Interfaces:

WarmUpStrategy<LoadAllWarmUpConfiguration>

public class LoadAllWarmUpStrategy
extends Object
implements WarmUpStrategy<LoadAllWarmUpConfiguration>

"Load all" warm-up strategy, which loads pages to persistent data region until it reaches DataRegionConfiguration.getMaxSize() with priority to index partitions. Loading occurs sequentially for each cache group, starting with index partition, and then all others in ascending order.

Constructor Summary

Constructors

Constructor and Description
LoadAllWarmUpStrategy(IgniteLogger log, Supplier<Collection<CacheGroupContext>> grpCtxSup) Constructor.

Method Summary

Modifier and Type	Method and Description
protected long	availableLoadPageCount(DataRegion region) Getting count of pages available for loading into data region.
Class<LoadAllWarmUpConfiguration>	configClass() Returns configuration class for mapping to strategy.
protected Map<CacheGroupContext,List<org.apache.ignite.internal.processors.cache.warmup.LoadAllWarmUpStrategy.LoadPartition>>	loadDataInfo(DataRegion region) Calculation of cache groups, partitions and count of pages that can load into data region.
void	stop() Stop warming up.
String	toString()
void	warmUp(LoadAllWarmUpConfiguration cfg, DataRegion region) Warm up.

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadAllWarmUpStrategy

public LoadAllWarmUpStrategy(IgniteLogger log,
                             Supplier<Collection<CacheGroupContext>> grpCtxSup)

Constructor.

Parameters:

log - Logger.

grpCtxSup - Cache group contexts supplier. Since GridCacheProcessor starts later.

Method Detail

configClass

public Class<LoadAllWarmUpConfiguration> configClass()

Returns configuration class for mapping to strategy.

Specified by:

configClass in interface WarmUpStrategy<LoadAllWarmUpConfiguration>

Returns:

Configuration class.

warmUp

public void warmUp(LoadAllWarmUpConfiguration cfg,
                   DataRegion region)
            throws IgniteCheckedException

Warm up.

Specified by:

warmUp in interface WarmUpStrategy<LoadAllWarmUpConfiguration>

Parameters:

cfg - Warm-up configuration.

region - Data region.

Throws:

IgniteCheckedException - if faild.

stop

public void stop()
          throws IgniteCheckedException

Stop warming up.

Specified by:

stop in interface WarmUpStrategy<LoadAllWarmUpConfiguration>

Throws:

IgniteCheckedException - if faild.

toString

public String toString()

Overrides:

toString in class Object

availableLoadPageCount

protected long availableLoadPageCount(DataRegion region)

Getting count of pages available for loading into data region.

Parameters:

region - Data region.

Returns:

Count(non-negative) of pages available for loading into data region.

loadDataInfo

protected Map<CacheGroupContext,List<org.apache.ignite.internal.processors.cache.warmup.LoadAllWarmUpStrategy.LoadPartition>> loadDataInfo(DataRegion region)
                                                                                                                                    throws IgniteCheckedException

Calculation of cache groups, partitions and count of pages that can load into data region. Calculation starts and includes an index partition for each group.

Parameters:

region - Data region.

Returns:

Loadable groups and partitions.

Throws:

IgniteCheckedException - – if faild.