public class StreamerHashIndexProvider<E,K,V> extends StreamerIndexProviderAdapter<E,K,V>
StreamerIndexProvider
.
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 StreamerTreeIndexProvider
.
StreamerTreeIndexProvider
StreamerIndexProviderAdapter.DedupTrackingEntry<E,K,V>, StreamerIndexProviderAdapter.Entry<E,K,V>, StreamerIndexProviderAdapter.EventTrackingEntry<E,K,V>, StreamerIndexProviderAdapter.IndexKey<V>, StreamerIndexProviderAdapter.NonTrackingEntry<E,K,V>
entryToKey, entryToVal
Constructor and Description |
---|
StreamerHashIndexProvider() |
Modifier and Type | Method and Description |
---|---|
protected void |
add(E evt,
K key,
StreamerIndexUpdateSync sync)
Add event to the index.
|
protected void |
endUpdate0(StreamerIndexUpdateSync sync,
E evt,
K key,
boolean rollback) |
protected StreamerIndex<E,K,V> |
index0() |
void |
initialize()
Initializes the index.
|
protected void |
remove(E evt,
K key,
StreamerIndexUpdateSync 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. |
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
protected StreamerIndex<E,K,V> index0()
index0
in class StreamerIndexProviderAdapter<E,K,V>
public void initialize()
public void reset0()
reset0
in class StreamerIndexProviderAdapter<E,K,V>
protected void add(E evt, K key, StreamerIndexUpdateSync sync)
add
in class StreamerIndexProviderAdapter<E,K,V>
evt
- Event.key
- key.sync
- Sync.protected void remove(E evt, K key, StreamerIndexUpdateSync sync)
remove
in class StreamerIndexProviderAdapter<E,K,V>
evt
- Event.key
- Key.sync
- Sync.protected void endUpdate0(StreamerIndexUpdateSync sync, E evt, K key, boolean rollback)
endUpdate0
in class StreamerIndexProviderAdapter<E,K,V>
sync
- Sync.evt
- Event.key
- Key.rollback
- Rollback flag.public boolean sorted()
true
if index supports sorting and therefore can perform range operations.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015