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

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 and Description
protected GridFutureAdapter<Void>	buildIdxFut Future for create/rebuild index.
protected IgniteLogger	log Logger.

Constructor Summary

Constructors

Constructor and Description
SchemaIndexCacheVisitorImpl(GridCacheContext cctx, @Nullable SchemaIndexCacheFilter rowFilter, @Nullable SchemaIndexOperationCancellationToken cancel, GridFutureAdapter<Void> buildIdxFut) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	beforeExecute() This method is called before creating or rebuilding indexes.
String	toString()
void	visit(SchemaIndexCacheVisitorClosure clo) Visit cache entries and pass them to closure.

Methods inherited from class java.lang.Object

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

Field Detail

buildIdxFut

protected final GridFutureAdapter<Void> buildIdxFut

Future for create/rebuild index.

log

protected IgniteLogger log

Logger.

Constructor Detail

SchemaIndexCacheVisitorImpl

public SchemaIndexCacheVisitorImpl(GridCacheContext cctx,
                                   @Nullable
                                   @Nullable SchemaIndexCacheFilter rowFilter,
                                   @Nullable
                                   @Nullable SchemaIndexOperationCancellationToken cancel,
                                   GridFutureAdapter<Void> buildIdxFut)

Constructor.

Parameters:

cctx - Cache context.

rowFilter - Row filter.

cancel - 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:

visit in interface SchemaIndexCacheVisitor

Parameters:

clo - Closure.

beforeExecute

protected void beforeExecute()

This method is called before creating or rebuilding indexes. Used only for test.

toString

public String toString()

Overrides:

toString in class Object