@ThreadSafe public final class StoreValuesQuery extends PointValuesQuery.Abstract implements Serializable
Holds responsibilities related to the preparation, transmission and processing of point values queries.
Modifier and Type | Class and Description |
---|---|
static class |
StoreValuesQuery.Builder
Builder.
|
static class |
StoreValuesQuery.IterationException
Iteration exception.
|
class |
StoreValuesQuery.Mark
Mark.
|
PointValuesQuery.Abstract
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object object) |
int |
getLimit()
Gets the limit.
|
Optional<UUID> |
getPointUUID()
Gets the point's UUID.
|
Optional<ElapsedTime> |
getPolatorTimeLimit()
Gets the polator time limit.
|
StoreValues |
getResponse()
Gets the response from the point's store.
|
int |
getRows()
Gets the rows.
|
Optional<Sync> |
getSync()
Gets the sync object.
|
int |
getType()
Gets this store query's type.
|
int |
hashCode()
/**
|
boolean |
isAll()
Asks if this store query is for all values within an interval.
|
boolean |
isAny()
Asks if this store query is for any values.
|
boolean |
isCancelled()
Asks if this store query has been cancelled.
|
boolean |
isCount()
Asks if only the count of the requested values is needed.
|
boolean |
isExtrapolated()
Gets the extrapolated indicator.
|
boolean |
isFixed()
Asks if the number of values to retrieve is fixed.
|
boolean |
isForward()
Asks if this store query asks for values in forward order.
|
boolean |
isIncludeDeleted()
Asks if this query includes deleted values.
|
boolean |
isInterpolated()
Gets the interpolated indicator.
|
boolean |
isMarked()
Asks if this store query is the result of a mark.
|
boolean |
isMultiple()
Asks if this store query asks for multiple values.
|
boolean |
isNormalized()
Gets the normalized indicator.
|
boolean |
isNotNull()
Gets the not null indicator.
|
boolean |
isPolated()
Asks if this is for inter/extra-polated values.
|
boolean |
isPull()
Asks if this is a pull query.
|
boolean |
isReverse()
Asks if this store query asks for values in reverse order.
|
boolean |
isSynced()
Asks if this is a synced query.
|
Iterable<PointValue> |
iterate()
Iterates on the point values returned for this store query.
|
static StoreValuesQuery.Builder |
newBuilder()
Returns a new builder.
|
StoreValuesQuery.Mark |
newMark(Optional<UUID> pointUUID,
DateTime stamp,
int done)
Returns a new mark.
|
void |
setCancelled(boolean cancelled)
Sets the 'cancelled' indicator.
|
String |
toString() |
getInterval, getPoint
@Nonnull @CheckReturnValue public static StoreValuesQuery.Builder newBuilder()
public boolean equals(Object object)
equals
in class PointValuesQuery.Abstract
@CheckReturnValue public int getLimit()
The limit is the maximum number of values expected in a single response. When there is at least one supplementary value, the response will include a mark to help create a new store query for further values.
@Nonnull @CheckReturnValue public Optional<UUID> getPointUUID()
@Nonnull @CheckReturnValue public Optional<ElapsedTime> getPolatorTimeLimit()
@Nonnull @CheckReturnValue public StoreValues getResponse() throws InterruptedException, StoreAccessException
InterruptedException
- When the service is stopped.StoreAccessException
- When store access fails.@CheckReturnValue public int getRows()
The value of rows is the queried number of values. This may exceed the limit.
public Optional<Sync> getSync()
getSync
in interface PointValuesQuery
getSync
in class PointValuesQuery.Abstract
@CheckReturnValue public int getType()
The type is a bit mask representing caracteristics of this store query.
public int hashCode()
hashCode
in class PointValuesQuery.Abstract
@CheckReturnValue public boolean isAll()
@CheckReturnValue public boolean isAny()
@CheckReturnValue public boolean isCancelled()
@CheckReturnValue public boolean isCount()
public boolean isExtrapolated()
isExtrapolated
in interface PointValuesQuery
@CheckReturnValue public boolean isFixed()
@CheckReturnValue public boolean isForward()
@CheckReturnValue public boolean isIncludeDeleted()
public boolean isInterpolated()
isInterpolated
in interface PointValuesQuery
@CheckReturnValue public boolean isMarked()
@CheckReturnValue public boolean isMultiple()
@CheckReturnValue public boolean isNormalized()
public boolean isNotNull()
isNotNull
in interface PointValuesQuery
public boolean isPolated()
isPolated
in interface PointValuesQuery
@CheckReturnValue public boolean isPull()
@CheckReturnValue public boolean isReverse()
@CheckReturnValue public boolean isSynced()
@Nonnull @CheckReturnValue public Iterable<PointValue> iterate()
The iteration can extend beyond the store query limit.
Note: the returned iterable and its iterator are not thread safe.
@Nonnull @CheckReturnValue public StoreValuesQuery.Mark newMark(@Nonnull Optional<UUID> pointUUID, @Nonnull DateTime stamp, int done)
pointUUID
- The optional UUID of the next point value.stamp
- The time stamp of the next point value.done
- The number of values already produced.public void setCancelled(boolean cancelled)
cancelled
- The new value for the indicator.public String toString()
toString
in class Object
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.