Package org.apache.ignite.internal.management.cache

Class ValidateIndexesClosure

java.lang.Object

org.apache.ignite.internal.management.cache.ValidateIndexesClosure

All Implemented Interfaces:

Serializable, Callable<ValidateIndexesJobResult>, IgniteCallable<ValidateIndexesJobResult>

public class ValidateIndexesClosure
extends Object
implements IgniteCallable<ValidateIndexesJobResult>

Closure that locally validates indexes of given caches. Validation consists of four checks: 1. If entry is present in cache data tree, it's reachable from all cache SQL indexes 2. If entry is present in cache SQL index, it can be dereferenced with link from index 3. If entry is present in cache SQL index, it's present in cache data tree 4. If size of cache and index on same table are not same

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static String	CANCELLED_MSG	Exception message throwing when closure was cancelled.

Constructor Summary

Constructors

Constructor	Description
ValidateIndexesClosure(ValidateIndexesContext validateCtx, Set<String> cacheNames, int checkFirst, int checkThrough, boolean checkCrc, boolean checkSizes)	Constructor.

Method Summary

Modifier and Type	Method	Description
ValidateIndexesJobResult	call()

Methods inherited from class java.lang.Object

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

Field Detail

CANCELLED_MSG

public static final String CANCELLED_MSG

Exception message throwing when closure was cancelled.

See Also:

Constant Field Values

Constructor Detail

ValidateIndexesClosure

public ValidateIndexesClosure(ValidateIndexesContext validateCtx,
                              Set<String> cacheNames,
                              int checkFirst,
                              int checkThrough,
                              boolean checkCrc,
                              boolean checkSizes)

Constructor.

Parameters:

validateCtx - Context of validate index closure.

cacheNames - Cache names.

checkFirst - If positive only first K elements will be validated.

checkThrough - If positive only each Kth element will be validated.

checkCrc - Check CRC sum on stored pages on disk.

checkSizes - Check that index size and cache size are same.

Method Detail

call

public ValidateIndexesJobResult call()
                              throws Exception

Specified by:

call in interface Callable<ValidateIndexesJobResult>

Throws:

Exception