client/me.ahoo.wow.client.java/JavaRowQueries

JavaRowQueries

@JvmSuppressWildcards

open class JavaRowQueries<R : Any>

RowQueries for Java callers: each query blocking, or asynchronous with the Async suffix.

Inheritors

JavaModelQueries

Functions

fun <G : Any> aggregate(query: AggregationQuery, groupType: Class<G>): List<G>

The groups of query, each as groupType (RowQueries.aggregate).

fun <G : Any> aggregateAsync(query: AggregationQuery, groupType: Class<G>): CompletableFuture<List<G>>

fun count(query: CountQuery): CountResult

How many rows query matches (RowQueries.count).

fun countAsync(query: CountQuery): CompletableFuture<CountResult>

fun cursor(query: CursorQuery): CursorPage<R>

One keyset page of the rows query matches (RowQueries.cursor).

fun cursorAsync(query: CursorQuery): CompletableFuture<CursorPage<R>>

fun list(query: ListQuery): List<R>

The rows query matches, read whole (RowQueries.list).

fun listAsync(query: ListQuery): CompletableFuture<List<R>>

fun paged(query: PagedQuery): PagedList<R>

One page of the rows query matches (RowQueries.paged).

fun pagedAsync(query: PagedQuery): CompletableFuture<PagedList<R>>

fun single(query: SingleQuery): R?

The first row query matches, or null.

fun singleAsync(query: SingleQuery): CompletableFuture<R?>

fun stream(query: ListQuery, after: String? = null): Stream<Positioned<R>>

The rows query matches as a resumable stream (RowQueries.stream), from after the position after when given; close it (try-with-resources) to stop reading early.