Package org.redisson.api
Interface RTimeSeriesAsync<V>
-
- All Superinterfaces:
RExpirableAsync
,RObjectAsync
- All Known Subinterfaces:
RTimeSeries<V>
- All Known Implementing Classes:
RedissonTimeSeries
public interface RTimeSeriesAsync<V> extends RExpirableAsync
Async interface for Redis based time-series collection.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description >
<,V> objects)
Adds all elements contained in the specified map to this time-series collection.>
<,V> objects, long timeToLive, timeUnit)
Adds all elements contained in the specified map to this time-series collection.>
addAsync(long timestamp, V object)
Adds element to this time-series collection by specifiedtimestamp
.>
addAsync(long timestamp, V object, long timeToLive, timeUnit)
Adds element to this time-series collection by specifiedtimestamp
.<TimeSeriesEntry<V>>>
entryRangeAsync(long startTimestamp, long endTimestamp)
Returns ordered entries of this time-series collection within timestamp range.<TimeSeriesEntry<V>>>
entryRangeReversedAsync(long startTimestamp, long endTimestamp)
Returns entries of this time-series collection in reverse order within timestamp range.RFuture<V>
firstAsync()
Returns the head element ornull
if this time-series collection is empty.<V>>
firstAsync(int count)
Returns the head elements of this time-series collection.>
firstTimestampAsync()
Returns timestamp of the head timestamp ornull
if this time-series collection is empty.RFuture<V>
getAsync(long timestamp)
Returns object by specifiedtimestamp
ornull
if it doesn't exist.RFuture<V>
lastAsync()
Returns the tail element ornull
if this time-series collection is empty.<V>>
lastAsync(int count)
Returns the tail elements of this time-series collection.>
lastTimestampAsync()
Returns timestamp of the tail element ornull
if this time-series collection is empty.RFuture<V>
pollFirstAsync()
Removes and returns the head element ornull
if this time-series collection is empty.<V>>
pollFirstAsync(int count)
Removes and returns the head elements ornull
if this time-series collection is empty.RFuture<V>
pollLastAsync()
Removes and returns the tail element ornull
if this time-series collection is empty.<V>>
pollLastAsync(int count)
Removes and returns the tail elements ornull
if this time-series collection is empty.<V>>
rangeAsync(long startTimestamp, long endTimestamp)
Returns ordered elements of this time-series collection within timestamp range.<V>>
rangeReversedAsync(long startTimestamp, long endTimestamp)
Returns elements of this time-series collection in reverse order within timestamp range.>
removeAsync(long timestamp)
Removes object by specifiedtimestamp
.>
removeRangeAsync(long startTimestamp, long endTimestamp)
Removes values within timestamp range.>
sizeAsync()
Returns size of this set.-
Methods inherited from interface org.redisson.api.RExpirableAsync
clearExpireAsync, expireAsync, expireAsync, expireAtAsync, expireAtAsync, remainTimeToLiveAsync
-
Methods inherited from interface org.redisson.api.RObjectAsync
addListenerAsync, copyAsync, deleteAsync, dumpAsync, getIdleTimeAsync, isExistsAsync, migrateAsync, moveAsync, removeListenerAsync, renameAsync, renamenxAsync, restoreAndReplaceAsync, restoreAndReplaceAsync, restoreAsync, restoreAsync, sizeInMemoryAsync, touchAsync, unlinkAsync
-
-
-
-
Method Detail
-
addAsync
> addAsync(long timestamp, V object)
Adds element to this time-series collection by specifiedtimestamp
.- Parameters:
timestamp
- - object timestampobject
- - object itself- Returns:
- void
-
addAllAsync
> addAllAsync(<,V> objects)
Adds all elements contained in the specified map to this time-series collection. Map contains of timestamp mapped by object.- Parameters:
objects
- - map of elements to add- Returns:
- void
-
addAsync
> addAsync(long timestamp, V object, long timeToLive, timeUnit)
Adds element to this time-series collection by specifiedtimestamp
.- Parameters:
timestamp
- - object timestampobject
- - object itselftimeToLive
- - time to live intervaltimeUnit
- - unit of time to live interval- Returns:
- void
-
addAllAsync
> addAllAsync(<,V> objects, long timeToLive, timeUnit)
Adds all elements contained in the specified map to this time-series collection. Map contains of timestamp mapped by object.- Parameters:
objects
- - map of elements to addtimeToLive
- - time to live intervaltimeUnit
- - unit of time to live interval- Returns:
- void
-
sizeAsync
> sizeAsync()
Returns size of this set.- Returns:
- size
-
getAsync
RFuture<V> getAsync(long timestamp)
Returns object by specifiedtimestamp
ornull
if it doesn't exist.- Parameters:
timestamp
- - object timestamp- Returns:
- object
-
removeAsync
> removeAsync(long timestamp)
Removes object by specifiedtimestamp
.- Parameters:
timestamp
- - object timestamp- Returns:
true
if an element was removed as a result of this call
-
pollFirstAsync
<V>> pollFirstAsync(int count)
Removes and returns the head elements ornull
if this time-series collection is empty.- Parameters:
count
- - elements amount- Returns:
- the head element,
or
null
if this time-series collection is empty
-
pollLastAsync
<V>> pollLastAsync(int count)
Removes and returns the tail elements ornull
if this time-series collection is empty.- Parameters:
count
- - elements amount- Returns:
- the tail element or
null
if this time-series collection is empty
-
pollFirstAsync
RFuture<V> pollFirstAsync()
Removes and returns the head element ornull
if this time-series collection is empty.- Returns:
- the head element,
or
null
if this time-series collection is empty
-
pollLastAsync
RFuture<V> pollLastAsync()
Removes and returns the tail element ornull
if this time-series collection is empty.- Returns:
- the tail element or
null
if this time-series collection is empty
-
lastAsync
RFuture<V> lastAsync()
Returns the tail element ornull
if this time-series collection is empty.- Returns:
- the tail element or
null
if this time-series collection is empty
-
firstAsync
RFuture<V> firstAsync()
Returns the head element ornull
if this time-series collection is empty.- Returns:
- the head element or
null
if this time-series collection is empty
-
firstTimestampAsync
> firstTimestampAsync()
Returns timestamp of the head timestamp ornull
if this time-series collection is empty.- Returns:
- timestamp or
null
if this time-series collection is empty
-
lastTimestampAsync
> lastTimestampAsync()
Returns timestamp of the tail element ornull
if this time-series collection is empty.- Returns:
- timestamp or
null
if this time-series collection is empty
-
lastAsync
<V>> lastAsync(int count)
Returns the tail elements of this time-series collection.- Parameters:
count
- - elements amount- Returns:
- the tail elements
-
firstAsync
<V>> firstAsync(int count)
Returns the head elements of this time-series collection.- Parameters:
count
- - elements amount- Returns:
- the head elements
-
removeRangeAsync
> removeRangeAsync(long startTimestamp, long endTimestamp)
Removes values within timestamp range. Including boundary values.- Parameters:
startTimestamp
- - start timestampendTimestamp
- - end timestamp- Returns:
- number of removed elements
-
rangeAsync
<V>> rangeAsync(long startTimestamp, long endTimestamp)
Returns ordered elements of this time-series collection within timestamp range. Including boundary values.- Parameters:
startTimestamp
- - start timestampendTimestamp
- - end timestamp- Returns:
- elements collection
-
rangeReversedAsync
<V>> rangeReversedAsync(long startTimestamp, long endTimestamp)
Returns elements of this time-series collection in reverse order within timestamp range. Including boundary values.- Parameters:
startTimestamp
- - start timestampendTimestamp
- - end timestamp- Returns:
- elements collection
-
entryRangeAsync
<TimeSeriesEntry<V>>> entryRangeAsync(long startTimestamp, long endTimestamp)
Returns ordered entries of this time-series collection within timestamp range. Including boundary values.- Parameters:
startTimestamp
- - start timestampendTimestamp
- - end timestamp- Returns:
- elements collection
-
entryRangeReversedAsync
<TimeSeriesEntry<V>>> entryRangeReversedAsync(long startTimestamp, long endTimestamp)
Returns entries of this time-series collection in reverse order within timestamp range. Including boundary values.- Parameters:
startTimestamp
- - start timestampendTimestamp
- - end timestamp- Returns:
- elements collection
-
-