Package | Description |
---|---|
org.apache.ignite.streamer.index |
Contains APIs for indexing of streamer windows.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
StreamerIndexProviderAdapter.DedupTrackingEntry<E,K,V>
Entry with index policy
StreamerIndexPolicy.EVENT_TRACKING_ON_DEDUP . |
protected static class |
StreamerIndexProviderAdapter.Entry<E,K,V>
Streamer window index entry.
|
protected static class |
StreamerIndexProviderAdapter.EventTrackingEntry<E,K,V>
Entry with index policy
StreamerIndexPolicy.EVENT_TRACKING_ON . |
protected static class |
StreamerIndexProviderAdapter.NonTrackingEntry<E,K,V>
Entry with index policy
StreamerIndexPolicy.EVENT_TRACKING_OFF . |
Modifier and Type | Field and Description |
---|---|
protected IgniteClosure<StreamerIndexEntry<E,K,V>,K> |
StreamerIndexProviderAdapter.entryToKey |
protected IgniteClosure<StreamerIndexEntry<E,K,V>,V> |
StreamerIndexProviderAdapter.entryToVal |
Modifier and Type | Method and Description |
---|---|
StreamerIndexEntry<E,K,V> |
StreamerIndex.entry(K key)
Gets index entry for given key.
|
StreamerIndexEntry<E,K,V> |
StreamerIndex.firstEntry()
Gets first entry in the index.
|
StreamerIndexEntry<E,K,V> |
StreamerIndex.lastEntry()
Gets last entry in the index.
|
Modifier and Type | Method and Description |
---|---|
Collection<StreamerIndexEntry<E,K,V>> |
StreamerIndex.entries(int cnt)
Gets read-only collection of entries in the index.
|
Set<StreamerIndexEntry<E,K,V>> |
StreamerIndex.entrySet(boolean asc,
V fromVal,
boolean fromIncl,
V toVal,
boolean toIncl)
Gets read-only set of index entries within given value range.
|
Set<StreamerIndexEntry<E,K,V>> |
StreamerIndex.entrySet(V val)
Gets read-only set of index entries with given value.
|
Modifier and Type | Method and Description |
---|---|
protected StreamerIndexProviderAdapter.Entry<E,K,V> |
StreamerIndexProviderAdapter.addEvent(StreamerIndexEntry<E,K,V> oldEntry,
K key,
V val,
StreamerIndexProviderAdapter.IndexKey<V> idxKey,
E evt) |
V |
StreamerIndexUpdater.onAdded(StreamerIndexEntry<E,K,V> entry,
E evt)
Callback invoked whenever an event is being added to the window.
|
V |
StreamerIndexUpdater.onRemoved(StreamerIndexEntry<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 StreamerIndexProviderAdapter.Entry<E,K,V> |
StreamerIndexProviderAdapter.removeEvent(StreamerIndexEntry<E,K,V> oldEntry,
K key,
V val,
StreamerIndexProviderAdapter.IndexKey<V> idxKey,
E evt) |
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015