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

public class SchemaIndexCachePartitionWorker
extends GridWorker

Worker for creating/rebuilding indexes for cache per partition.

Field Summary

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

isCancelled, log

Constructor Summary

Constructors

Constructor and Description
SchemaIndexCachePartitionWorker(GridCacheContext cctx, GridDhtLocalPartition locPart, AtomicBoolean stop, SchemaIndexOperationCancellationToken cancel, SchemaIndexCacheVisitorClosure clo, GridFutureAdapter<SchemaIndexCacheStat> fut, @Nullable SchemaIndexCacheFilter rowFilter, AtomicInteger partsCnt) Constructor.

Method Summary

Modifier and Type	Method and 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, onIdle, run, runner, updateHeartbeat

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaIndexCachePartitionWorker

public SchemaIndexCachePartitionWorker(GridCacheContext cctx,
                                       GridDhtLocalPartition locPart,
                                       AtomicBoolean stop,
                                       SchemaIndexOperationCancellationToken cancel,
                                       SchemaIndexCacheVisitorClosure clo,
                                       GridFutureAdapter<SchemaIndexCacheStat> fut,
                                       @Nullable
                                       @Nullable SchemaIndexCacheFilter rowFilter,
                                       AtomicInteger partsCnt)

Constructor.

Parameters:

cctx - Cache context.

locPart - Partition.

stop - Stop flag between all workers for one cache.

cancel - Cancellation token between all workers for all caches.

clo - Index closure.

fut - Worker future.

rowFilter - Row filter.

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