Class SchemaIndexCacheVisitorImpl
- java.lang.Object
-
- org.apache.ignite.internal.processors.query.schema.SchemaIndexCacheVisitorImpl
-
- All Implemented Interfaces:
SchemaIndexCacheVisitor
public class SchemaIndexCacheVisitorImpl extends Object implements SchemaIndexCacheVisitor
Visitor who create/rebuild indexes in parallel by partition for a given cache.
-
-
Field Summary
Fields Modifier and Type Field Description protected GridFutureAdapter<Void>buildIdxFutFuture for create/rebuild index.protected IgniteLoggerlogLogger.
-
Constructor Summary
Constructors Constructor Description SchemaIndexCacheVisitorImpl(GridCacheContext<?,?> cctx, IndexRebuildCancelToken cancelTok, GridFutureAdapter<Void> buildIdxFut)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidbeforeExecute()This method is called before creating or rebuilding indexes.StringtoString()voidvisit(SchemaIndexCacheVisitorClosure clo)Visit cache entries and pass them to closure.
-
-
-
Field Detail
-
buildIdxFut
protected final GridFutureAdapter<Void> buildIdxFut
Future for create/rebuild index.
-
log
protected final IgniteLogger log
Logger.
-
-
Constructor Detail
-
SchemaIndexCacheVisitorImpl
public SchemaIndexCacheVisitorImpl(GridCacheContext<?,?> cctx, IndexRebuildCancelToken cancelTok, GridFutureAdapter<Void> buildIdxFut)
Constructor.- Parameters:
cctx- Cache context.cancelTok- Cancellation token.buildIdxFut- Future for create/rebuild index.
-
-
Method Detail
-
visit
public void visit(SchemaIndexCacheVisitorClosure clo)
Visit cache entries and pass them to closure.- Specified by:
visitin interfaceSchemaIndexCacheVisitor- Parameters:
clo- Closure.
-
beforeExecute
protected void beforeExecute()
This method is called before creating or rebuilding indexes. Used only for test.
-
-