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 intDFLT_IGNITE_INDEX_REBUILD_BATCH_SIZEDefault 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidbody()The implementation should provide the execution body for this runnable.StringtoString()-
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
-
-
-
-
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, IgniteInterruptedCheckedExceptionThe implementation should provide the execution body for this runnable.- Specified by:
bodyin classGridWorker- Throws:
InterruptedException- Thrown in case of interruption.IgniteInterruptedCheckedException- If interrupted.
-
toString
public String toString()
- Overrides:
toStringin classGridWorker
-
-