Package io.streamthoughts.azkarra.runtime.query

Class BaseAsyncQueryCall<K,V,Q extends Query>

java.lang.Object

io.streamthoughts.azkarra.api.query.DecorateQuery<Q>

io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall<K,V,Q>

All Implemented Interfaces:

Query, QueryCall<K,V>

Direct Known Subclasses:

DistributedQueryCall, EmptyQueryCall, LocalQueryCall

public abstract class BaseAsyncQueryCall<K,V,Q extends Query>
extends DecorateQuery<Q>
implements QueryCall<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface io.streamthoughts.azkarra.api.query.QueryCall

QueryCall.QueryCallFactory

Field Summary

Fields inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

query

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseAsyncQueryCall(Q query)	Creates a new BaseAsyncQueryCall instance.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancels the QueryCall, if possible.
CompletableFuture<QueryResult<K,V>>	executeAsync(QueryOptions options)	Executes this QueryCall asynchronously.
void	executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)	Executes this QueryCall asynchronously.
boolean	isCanceled()
boolean	isExecuted()
void	setIsExecuted(boolean isExecuted)

Methods inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

equals, getParams, getStoreName, getStoreOperation, getStoreType, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.query.Query

getParams, getStoreName, getStoreOperation, getStoreType

Methods inherited from interface io.streamthoughts.azkarra.api.query.QueryCall

execute, renew

Constructor Detail

BaseAsyncQueryCall

protected BaseAsyncQueryCall(Q query)

Creates a new BaseAsyncQueryCall instance.

Parameters:

query - the query.

Method Detail

executeAsync

public CompletableFuture<QueryResult<K,V>> executeAsync(QueryOptions options)

Executes this QueryCall asynchronously.

Specified by:

executeAsync in interface QueryCall<K,V>

Parameters:

options - the options to be used.

Returns:

a CompletableFuture of QueryResult.

executeAsync

public void executeAsync(QueryOptions options,
                         Consumer<QueryResult<K,V>> resultCallback)

Executes this QueryCall asynchronously.

Specified by:

executeAsync in interface QueryCall<K,V>

Parameters:

options - the options to be used.

resultCallback - the callback to be invoked when this QueryCall complete with either a success result or a failure exception.

cancel

public void cancel()

Cancels the QueryCall, if possible. QueryCall that are already complete cannot be canceled.

Specified by:

cancel in interface QueryCall<K,V>

isExecuted

public boolean isExecuted()

Specified by:

isExecuted in interface QueryCall<K,V>

Returns:

true if this QueryCall has already been executed.

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface QueryCall<K,V>

Returns:

true if this QueryCall has already been canceled.

setIsExecuted

public void setIsExecuted(boolean isExecuted)