Package io.streamthoughts.azkarra.runtime.query

Class LocalQueryCall<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.LocalQueryCall<K,V>

All Implemented Interfaces:

Query, QueryCall<K,V>

public class LocalQueryCall<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
LocalQueryCall(LocalKafkaStreamsContainer container, LocalExecutableQuery<K,V> query)	Creates a new DecorateQuery instance.

Method Summary

Modifier and Type	Method	Description
QueryResult<K,V>	execute(QueryOptions options)	Executes this QueryCall.
Endpoint	getLocalEndpoint()
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

LocalQueryCall

public LocalQueryCall(LocalKafkaStreamsContainer container,
                      LocalExecutableQuery<K,V> query)

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.

getLocalEndpoint

public Endpoint getLocalEndpoint()

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.