Package io.streamthoughts.azkarra.runtime.query

Class DistributedQueryCall<K,V>

java.lang.Object

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

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

io.streamthoughts.azkarra.runtime.query.DistributedQueryCall<K,V>

All Implemented Interfaces:

Query, QueryCall<K,V>

public class DistributedQueryCall<K,V>
extends BaseAsyncQueryCall<K,V,LocalExecutableQuery<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

Constructor	Description
DistributedQueryCall(LocalExecutableQuery<K,V> query, LocalKafkaStreamsContainer container, RemoteQueryCallFactory callFactory)	Creates a new DecorateQuery instance.

Method Summary

Modifier and Type	Method	Description
QueryResult<K,V>	execute(QueryOptions options)	Executes this QueryCall.
QueryCall<K,V>	renew()	Create a new, identical QueryCall to this one which can be re-executed even if this call has already been.

Methods inherited from class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall

cancel, executeAsync, executeAsync, isCanceled, isExecuted, setIsExecuted

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

Constructor Detail

DistributedQueryCall

public DistributedQueryCall(LocalExecutableQuery<K,V> query,
                            LocalKafkaStreamsContainer container,
                            RemoteQueryCallFactory callFactory)

Creates a new DecorateQuery instance.

Parameters:

query - the query.

Method Detail

execute

public QueryResult<K,V> execute(QueryOptions options)

Executes this QueryCall.

Parameters:

options - the options to be used.

Returns:

the QueryResult.

renew

public QueryCall<K,V> renew()

Create a new, identical QueryCall to this one which can be re-executed even if this call has already been.