org.gridgain.grid.streamer.index.hash

Class GridStreamerHashIndexProvider<E,K,V>

java.lang.Object

org.gridgain.grid.streamer.index.GridStreamerIndexProviderAdapter<E,K,V>

org.gridgain.grid.streamer.index.hash.GridStreamerHashIndexProvider<E,K,V>

All Implemented Interfaces:

GridStreamerIndexProvider<E,K,V>, GridStreamerIndexProviderMBean

public class GridStreamerHashIndexProvider<E,K,V>
extends GridStreamerIndexProviderAdapter<E,K,V>

Hash index implementation of a GridStreamerIndexProvider.

This implementation uses a concurrent hash map, which is extremely efficient for CRUD operations. It does not, however, maintain the ordering of entries, so, operations which imply ordering are not supported.

If ordering is required, consider using GridStreamerTreeIndexProvider.

See Also:

GridStreamerTreeIndexProvider

Nested Class Summary

Nested classes/interfaces inherited from class org.gridgain.grid.streamer.index.GridStreamerIndexProviderAdapter

GridStreamerIndexProviderAdapter.DedupTrackingEntry<E,K,V>, GridStreamerIndexProviderAdapter.Entry<E,K,V>, GridStreamerIndexProviderAdapter.EventTrackingEntry<E,K,V>, GridStreamerIndexProviderAdapter.IndexKey<V>, GridStreamerIndexProviderAdapter.NonTrackingEntry<E,K,V>

Field Summary

Fields inherited from class org.gridgain.grid.streamer.index.GridStreamerIndexProviderAdapter

entryToKey, entryToVal

Constructor Summary

Constructors

Constructor and Description
GridStreamerHashIndexProvider()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	add(E evt, K key, GridStreamerIndexUpdateSync sync) Add event to the index.
protected void	endUpdate0(GridStreamerIndexUpdateSync sync, E evt, K key, boolean rollback)
protected GridStreamerIndex<E,K,V>	index0()
void	initialize() Initializes the index.
protected void	remove(E evt, K key, GridStreamerIndexUpdateSync sync) Remove event from the index.
void	reset0() Called on reset.
boolean	sorted() Returns true if index supports sorting and therefore can perform range operations.

Methods inherited from class org.gridgain.grid.streamer.index.GridStreamerIndexProviderAdapter

add, addEvent, addToCollection, addToMap, dispose, endUpdate, eventsCount, getName, getPolicy, getUpdater, index, isUnique, lockIndexKey, name, newEntry, policy, readLock, readUnlock, remove, removeEvent, removeFromCollection, removeFromMap, reset, setName, setPolicy, setUnique, setUpdater, size, toString, trieGet, unique, unlockIndexKey, updaterClass, writeLock, writeUnlock

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerHashIndexProvider

public GridStreamerHashIndexProvider()

Method Detail

index0

protected GridStreamerIndex<E,K,V> index0()

Specified by:

index0 in class GridStreamerIndexProviderAdapter<E,K,V>

Returns:

Index

initialize

public void initialize()

Initializes the index.

reset0

public void reset0()

Called on reset.

Specified by:

reset0 in class GridStreamerIndexProviderAdapter<E,K,V>

add

protected void add(E evt,
       K key,
       GridStreamerIndexUpdateSync sync)
            throws GridException

Add event to the index.

Specified by:

add in class GridStreamerIndexProviderAdapter<E,K,V>

Parameters:

evt - Event.

key - key.

sync - Sync.

Throws:

GridException - If failed.

remove

protected void remove(E evt,
          K key,
          GridStreamerIndexUpdateSync sync)
               throws GridException

Remove event from the index.

Specified by:

remove in class GridStreamerIndexProviderAdapter<E,K,V>

Parameters:

evt - Event.

key - Key.

sync - Sync.

Throws:

GridException - If failed.

endUpdate0

protected void endUpdate0(GridStreamerIndexUpdateSync sync,
              E evt,
              K key,
              boolean rollback)

Specified by:

endUpdate0 in class GridStreamerIndexProviderAdapter<E,K,V>

Parameters:

sync - Sync.

evt - Event.

key - Key.

rollback - Rollback flag.

sorted

public boolean sorted()

Returns true if index supports sorting and therefore can perform range operations.

Returns:

Index sorted flag.