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 keyFrom,
K keyTo)
Retrieve all aggregated sessions for the given range of keys.
|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFindSessions(K key,
Instant earliestSessionEndTime,
Instant 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.
|
default KeyValueIterator<Windowed<K>,AGG> |
backwardFindSessions(K keyFrom,
K keyTo,
Instant earliestSessionEndTime,
Instant 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 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 keyFrom,
K keyTo)
Retrieve all aggregated sessions for the given range of keys.
|
default AGG |
fetchSession(K key,
Instant earliestSessionEndTime,
Instant latestSessionStartTime)
Get the value of key from a single session.
|
default AGG |
fetchSession(K key,
long earliestSessionEndTime,
long latestSessionStartTime)
Get the value of key from a single session.
|
default KeyValueIterator<Windowed<K>,AGG> |
findSessions(K key,
Instant earliestSessionEndTime,
Instant 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 keyFrom,
K keyTo,
Instant earliestSessionEndTime,
Instant 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 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> findSessions(K key, Instant earliestSessionEndTime, Instant 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> backwardFindSessions(K key, Instant earliestSessionEndTime, Instant 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> findSessions(K keyFrom, K keyTo, Instant earliestSessionEndTime, Instant 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 KeyValueIterator<Windowed<K>,AGG> backwardFindSessions(K keyFrom, K keyTo, Instant earliestSessionEndTime, Instant 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 earliestSessionEndTime, long latestSessionStartTime)
key
- the key to fetchearliestSessionEndTime
- start timestamp of the sessionlatestSessionStartTime
- end timestamp of the sessionnull
if no session associated with the key can be foundNullPointerException
- If null
is used for any key.default AGG fetchSession(K key, Instant earliestSessionEndTime, Instant latestSessionStartTime)
key
- the key to fetchearliestSessionEndTime
- start timestamp of the sessionlatestSessionStartTime
- 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 keyFrom, K keyTo)
For each key, the iterator guarantees ordering of sessions, starting from the oldest/earliest available session to the newest/latest session.
keyFrom
- first key in the range to find aggregated session values forkeyTo
- 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 keyFrom, K keyTo)
For each key, the iterator guarantees ordering of sessions, starting from the newest/latest available session to the oldest/earliest session.
keyFrom
- first key in the range to find aggregated session values forkeyTo
- last key in the range to find aggregated session values forNullPointerException
- If null is used for any of the keys.