Package org.apache.ignite.internal.processors.query.schema

Class SchemaIndexCachePartitionWorker

java.lang.Object

org.apache.ignite.internal.util.worker.GridWorker

org.apache.ignite.internal.processors.query.schema.SchemaIndexCachePartitionWorker

All Implemented Interfaces:

Runnable, WorkProgressDispatcher

public class SchemaIndexCachePartitionWorker
extends GridWorker

Worker for creating/rebuilding indexes for cache per partition.

Field Summary

Fields

Modifier and Type	Field	Description
static int	DFLT_IGNITE_INDEX_REBUILD_BATCH_SIZE	Default count of rows, being processed within a single checkpoint lock.

Fields inherited from class org.apache.ignite.internal.util.worker.GridWorker

isCancelled, log

Constructor Summary

Constructors

Constructor	Description
SchemaIndexCachePartitionWorker(GridCacheContext cctx, GridDhtLocalPartition locPart, AtomicBoolean stop, IndexRebuildCancelToken cancelTok, SchemaIndexCacheVisitorClosure clo, GridFutureAdapter<SchemaIndexCacheStat> fut, AtomicInteger partsCnt)	Constructor.

Method Summary

Modifier and Type	Method	Description
protected void	body()	The implementation should provide the execution body for this runnable.
String	toString()

Methods inherited from class org.apache.ignite.internal.util.worker.GridWorker

blockingSectionBegin, blockingSectionEnd, cancel, cleanup, heartbeatTs, igniteInstanceName, isCancelled, isDone, join, name, onCancel, onCancelledBeforeWorkerScheduled, onIdle, run, runner, updateHeartbeat

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_IGNITE_INDEX_REBUILD_BATCH_SIZE

public static final int DFLT_IGNITE_INDEX_REBUILD_BATCH_SIZE

Default count of rows, being processed within a single checkpoint lock.

See Also:

Constant Field Values

Constructor Detail

SchemaIndexCachePartitionWorker

public SchemaIndexCachePartitionWorker(GridCacheContext cctx,
                                       GridDhtLocalPartition locPart,
                                       AtomicBoolean stop,
                                       IndexRebuildCancelToken cancelTok,
                                       SchemaIndexCacheVisitorClosure clo,
                                       GridFutureAdapter<SchemaIndexCacheStat> fut,
                                       AtomicInteger partsCnt)

Constructor.

Parameters:

cctx - Cache context.

locPart - Partition.

stop - Stop flag between all workers for one cache.

cancelTok - Cancellation token between all workers for all caches.

clo - Index closure.

fut - Worker future.

partsCnt - Count of partitions to be processed.

Method Detail

body

protected void body()
             throws InterruptedException,
                    IgniteInterruptedCheckedException

The implementation should provide the execution body for this runnable.

Specified by:

body in class GridWorker

Throws:

InterruptedException - Thrown in case of interruption.

IgniteInterruptedCheckedException - If interrupted.

toString

public String toString()

Overrides:

toString in class GridWorker