| Package | Description |
|---|---|
| org.gridgain.grid.streamer.index |
Contains APIs for indexing of streamer windows.
|
| Modifier and Type | Class and Description |
|---|---|
protected static class |
GridStreamerIndexProviderAdapter.DedupTrackingEntry<E,K,V>
Entry with index policy
GridStreamerIndexPolicy.EVENT_TRACKING_ON_DEDUP. |
protected static class |
GridStreamerIndexProviderAdapter.Entry<E,K,V>
Streamer window index entry.
|
protected static class |
GridStreamerIndexProviderAdapter.EventTrackingEntry<E,K,V>
Entry with index policy
GridStreamerIndexPolicy.EVENT_TRACKING_ON. |
protected static class |
GridStreamerIndexProviderAdapter.NonTrackingEntry<E,K,V>
Entry with index policy
GridStreamerIndexPolicy.EVENT_TRACKING_OFF. |
| Modifier and Type | Field and Description |
|---|---|
protected GridClosure<GridStreamerIndexEntry<E,K,V>,K> |
GridStreamerIndexProviderAdapter.entryToKey |
protected GridClosure<GridStreamerIndexEntry<E,K,V>,V> |
GridStreamerIndexProviderAdapter.entryToVal |
| Modifier and Type | Method and Description |
|---|---|
GridStreamerIndexEntry<E,K,V> |
GridStreamerIndex.entry(K key)
Gets index entry for given key.
|
GridStreamerIndexEntry<E,K,V> |
GridStreamerIndex.firstEntry()
Gets first entry in the index.
|
GridStreamerIndexEntry<E,K,V> |
GridStreamerIndex.lastEntry()
Gets last entry in the index.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridStreamerIndexEntry<E,K,V>> |
GridStreamerIndex.entries(int cnt)
Gets read-only collection of entries in the index.
|
Set<GridStreamerIndexEntry<E,K,V>> |
GridStreamerIndex.entrySet(boolean asc,
V fromVal,
boolean fromIncl,
V toVal,
boolean toIncl)
Gets read-only set of index entries within given value range.
|
Set<GridStreamerIndexEntry<E,K,V>> |
GridStreamerIndex.entrySet(V val)
Gets read-only set of index entries with given value.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridStreamerIndexProviderAdapter.Entry<E,K,V> |
GridStreamerIndexProviderAdapter.addEvent(GridStreamerIndexEntry<E,K,V> oldEntry,
K key,
V val,
GridStreamerIndexProviderAdapter.IndexKey<V> idxKey,
E evt) |
V |
GridStreamerIndexUpdater.onAdded(GridStreamerIndexEntry<E,K,V> entry,
E evt)
Callback invoked whenever an event is being added to the window.
|
V |
GridStreamerIndexUpdater.onRemoved(GridStreamerIndexEntry<E,K,V> entry,
E evt)
Callback invoked whenever an event is being removed from the window and has
index entry for given key.
|
protected GridStreamerIndexProviderAdapter.Entry<E,K,V> |
GridStreamerIndexProviderAdapter.removeEvent(GridStreamerIndexEntry<E,K,V> oldEntry,
K key,
V val,
GridStreamerIndexProviderAdapter.IndexKey<V> idxKey,
E evt) |
Copyright © 2014. All rights reserved.