org.apache.ignite.internal.managers.indexing

Class GridIndexingManager

java.lang.Object

org.apache.ignite.internal.managers.GridManagerAdapter<IndexingSpi>

org.apache.ignite.internal.managers.indexing.GridIndexingManager

All Implemented Interfaces:

GridComponent, GridManager

public class GridIndexingManager
extends GridManagerAdapter<IndexingSpi>

Manages cache indexing.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridIndexingManager(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
protected void	onKernalStop0(boolean cancel)
IgniteSpiCloseableIterator<?>	query(String cacheName, Collection<Object> params, IndexingQueryFilter filters)
void	remove(String cacheName, Object key)
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
<K,V> void	store(String cacheName, K key, V val, long expirationTime) Writes key-value pair to index.

Methods inherited from class org.apache.ignite.internal.managers.GridManagerAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, enabled, getSpi, getSpi, getSpis, inject, onAfterSpiStart, onBeforeSpiStart, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStart0, onKernalStop, onReconnected, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridIndexingManager

public GridIndexingManager(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Description copied from interface: GridComponent

Starts grid component.

Throws:

IgniteCheckedException - Thrown in case of any errors.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridManagerAdapter<IndexingSpi>

Parameters:

cancel - Cancel flag.

stop

public void stop(boolean cancel)
          throws IgniteCheckedException

Description copied from interface: GridComponent

Stops grid component.

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

IgniteCheckedException - Thrown in case of any errors.

store

public <K,V> void store(String cacheName,
                        K key,
                        V val,
                        long expirationTime)
                 throws IgniteCheckedException

Writes key-value pair to index.

Parameters:

cacheName - Cache name.

key - Key.

val - Value.

expirationTime - Expiration time or 0 if never expires.

Throws:

IgniteCheckedException - In case of error.

remove

public void remove(String cacheName,
                   Object key)
            throws IgniteCheckedException

Parameters:

cacheName - Cache name.

key - Key.

Throws:

IgniteCheckedException - Thrown in case of any errors.

query

public IgniteSpiCloseableIterator<?> query(String cacheName,
                                           Collection<Object> params,
                                           IndexingQueryFilter filters)
                                    throws IgniteCheckedException

Parameters:

cacheName - Cache name.

params - Parameters collection.

filters - Filters.

Returns:

Query result.

Throws:

IgniteCheckedException - If failed.