org.rvpf.store.server.the.sql

Class Responder

Object

Responder

All Implemented Interfaces:

StoreCursor.Responder

public final class Responder
extends Object
implements StoreCursor.Responder

Responder.

Constructor Summary

Constructors

Constructor and Description
Responder(TheStoreConnection connection, Points points, int backEndLimit, int statementsLimit) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
void	close() Closes this.
long	count() Returns the count of values that would satisfy the query.
TheStoreConnection	getConnection() Gets the store connection.
int	limit() Returns a limit on the number of values allowed by the backend.
Optional<VersionedValue>	next() Returns the next point value.
void	reset(Optional<StoreCursor> storeCursor) Resets this responder.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Responder

public Responder(@Nonnull
                 TheStoreConnection connection,
                 @Nonnull
                 Points points,
                 int backEndLimit,
                 int statementsLimit)

Constructs an instance.

Parameters:

connection - The connection to use for database services.

points - The point from which to get the point definitions.

backEndLimit - A limit on the number of values allowed.

statementsLimit - A limit on the number of cached statements.

Method Detail

close

public void close()

Closes this.

count

public long count()

Returns the count of values that would satisfy the query.

Specified by:

count in interface StoreCursor.Responder

Returns:

The count.

getConnection

@Nonnull
 @CheckReturnValue
public TheStoreConnection getConnection()

Gets the store connection.

Returns:

The store connection.

limit

public int limit()

Returns a limit on the number of values allowed by the backend.

Specified by:

limit in interface StoreCursor.Responder

Returns:

The limit.

next

public Optional<VersionedValue> next()

Returns the next point value.

Specified by:

next in interface StoreCursor.Responder

Returns:

The next point value (empty when done).

reset

public void reset(Optional<StoreCursor> storeCursor)

Resets this responder.

The responder should free resources reserved by a previous store query. If the store cursor parameter is not empty, it should prepare for calls to its StoreCursor.Responder.next() method.

Specified by:

reset in interface StoreCursor.Responder

Parameters:

storeCursor - The controlling store cursor (may be empty).