K
- the key typeAGG
- the aggregated value typepublic interface ReadOnlySessionStore<K,AGG>
Modifier and Type | Method and Description |
---|---|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFetch(K key)
Retrieve all aggregated sessions for the provided key.
|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFetch(K from,
K to)
Retrieve all aggregated sessions for the given range of keys.
|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFindSessions(K keyFrom,
K keyTo,
long earliestSessionEndTime,
long latestSessionStartTime)
Fetch any sessions in the given range of keys and the sessions end is ≥ earliestSessionEndTime and the sessions
start is ≤ latestSessionStartTime iterating from latest to earliest.
|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFindSessions(K key,
long earliestSessionEndTime,
long latestSessionStartTime)
Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions
start is ≤ latestSessionStartTime iterating from latest to earliest.
|
KeyValueIterator<Windowed<K>,AGG> |
fetch(K key)
Retrieve all aggregated sessions for the provided key.
|
KeyValueIterator<Windowed<K>,AGG> |
fetch(K from,
K to)
Retrieve all aggregated sessions for the given range of keys.
|
default AGG |
fetchSession(K key,
long startTime,
long endTime)
Get the value of key from a single session.
|
default KeyValueIterator<Windowed<K>,AGG> |
findSessions(K keyFrom,
K keyTo,
long earliestSessionEndTime,
long latestSessionStartTime)
Fetch any sessions in the given range of keys and the sessions end is ≥ earliestSessionEndTime and the sessions
start is ≤ latestSessionStartTime iterating from earliest to latest.
|
default KeyValueIterator<Windowed<K>,AGG> |
findSessions(K key,
long earliestSessionEndTime,
long latestSessionStartTime)
Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions
start is ≤ latestSessionStartTime iterating from earliest to latest.
|
default KeyValueIterator<Windowed<K>,AGG> findSessions(K key, long earliestSessionEndTime, long latestSessionStartTime)
This iterator must be closed after use.
key
- the key to return sessions forearliestSessionEndTime
- the end timestamp of the earliest session to search for, where iteration starts.latestSessionStartTime
- the end timestamp of the latest session to search for, where iteration ends.NullPointerException
- If null is used for key.default KeyValueIterator<Windowed<K>,AGG> backwardFindSessions(K key, long earliestSessionEndTime, long latestSessionStartTime)
This iterator must be closed after use.
key
- the key to return sessions forearliestSessionEndTime
- the end timestamp of the earliest session to search for, where iteration ends.latestSessionStartTime
- the end timestamp of the latest session to search for, where iteration starts.NullPointerException
- If null is used for key.default KeyValueIterator<Windowed<K>,AGG> findSessions(K keyFrom, K keyTo, long earliestSessionEndTime, long latestSessionStartTime)
This iterator must be closed after use.
keyFrom
- The first key that could be in the rangekeyTo
- The last key that could be in the rangeearliestSessionEndTime
- the end timestamp of the earliest session to search for, where iteration starts.latestSessionStartTime
- the end timestamp of the latest session to search for, where iteration ends.NullPointerException
- If null is used for any key.default KeyValueIterator<Windowed<K>,AGG> backwardFindSessions(K keyFrom, K keyTo, long earliestSessionEndTime, long latestSessionStartTime)
This iterator must be closed after use.
keyFrom
- The first key that could be in the rangekeyTo
- The last key that could be in the rangeearliestSessionEndTime
- the end timestamp of the earliest session to search for, where iteration ends.latestSessionStartTime
- the end timestamp of the latest session to search for, where iteration starts.NullPointerException
- If null is used for any key.default AGG fetchSession(K key, long startTime, long endTime)
key
- the key to fetchstartTime
- start timestamp of the sessionendTime
- end timestamp of the sessionnull
if no session associated with the key can be foundNullPointerException
- If null
is used for any key.KeyValueIterator<Windowed<K>,AGG> fetch(K key)
For each key, the iterator guarantees ordering of sessions, starting from the oldest/earliest available session to the newest/latest session.
key
- record key to find aggregated session values forNullPointerException
- If null is used for key.default KeyValueIterator<Windowed<K>,AGG> backwardFetch(K key)
For each key, the iterator guarantees ordering of sessions, starting from the newest/latest available session to the oldest/earliest session.
key
- record key to find aggregated session values forNullPointerException
- If null is used for key.KeyValueIterator<Windowed<K>,AGG> fetch(K from, K to)
For each key, the iterator guarantees ordering of sessions, starting from the oldest/earliest available session to the newest/latest session.
from
- first key in the range to find aggregated session values forto
- last key in the range to find aggregated session values forNullPointerException
- If null is used for any of the keys.default KeyValueIterator<Windowed<K>,AGG> backwardFetch(K from, K to)
For each key, the iterator guarantees ordering of sessions, starting from the newest/latest available session to the oldest/earliest session.
from
- first key in the range to find aggregated session values forto
- last key in the range to find aggregated session values forNullPointerException
- If null is used for any of the keys.