Package | Description |
---|---|
org.apache.ignite.streamer.index |
Contains APIs for indexing of streamer windows.
|
org.apache.ignite.streamer.index.hash |
Contains hash-based streamer index implementation.
|
org.apache.ignite.streamer.index.tree |
Contains tree-based streamer index implementation.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
StreamerIndexProviderAdapter.add(E evt,
K key,
StreamerIndexUpdateSync sync)
Add event to the index.
|
void |
StreamerIndexProviderAdapter.add(StreamerIndexUpdateSync sync,
E evt)
Add event to the index.
|
void |
StreamerIndexProvider.add(StreamerIndexUpdateSync sync,
E evt)
Adds an event to index.
|
void |
StreamerIndexProviderAdapter.endUpdate(StreamerIndexUpdateSync sync,
E evt,
boolean rollback,
boolean rmv)
Finalizes an update operation.
|
void |
StreamerIndexProvider.endUpdate(StreamerIndexUpdateSync sync,
E evt,
boolean rollback,
boolean rmv)
Finalizes an update operation.
|
protected abstract void |
StreamerIndexProviderAdapter.endUpdate0(StreamerIndexUpdateSync sync,
E evt,
K key,
boolean rollback) |
protected void |
StreamerIndexProviderAdapter.lockIndexKey(StreamerIndexProviderAdapter.IndexKey<V> key,
StreamerIndexUpdateSync sync)
Lock updates on particular key.
|
protected abstract void |
StreamerIndexProviderAdapter.remove(E evt,
K key,
StreamerIndexUpdateSync sync)
Remove event from the index.
|
void |
StreamerIndexProviderAdapter.remove(StreamerIndexUpdateSync sync,
E evt)
Remove event from the index.
|
void |
StreamerIndexProvider.remove(StreamerIndexUpdateSync sync,
E evt)
Removes an event from index.
|
protected void |
StreamerIndexProviderAdapter.unlockIndexKey(StreamerIndexProviderAdapter.IndexKey<V> key,
StreamerIndexUpdateSync sync)
Unlock updates on particular key.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StreamerHashIndexProvider.add(E evt,
K key,
StreamerIndexUpdateSync sync)
Add event to the index.
|
protected void |
StreamerHashIndexProvider.endUpdate0(StreamerIndexUpdateSync sync,
E evt,
K key,
boolean rollback) |
protected void |
StreamerHashIndexProvider.remove(E evt,
K key,
StreamerIndexUpdateSync sync)
Remove event from the index.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StreamerTreeIndexProvider.add(E evt,
K key,
StreamerIndexUpdateSync sync)
Add event to the index.
|
protected void |
StreamerTreeIndexProvider.endUpdate0(StreamerIndexUpdateSync sync,
E evt,
K key,
boolean rollback) |
protected void |
StreamerTreeIndexProvider.remove(E evt,
K key,
StreamerIndexUpdateSync sync)
Remove event from the index.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015