Package io.streamthoughts.azkarra.api.query

Class DistributedQuery<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.DistributedQuery<K,V>

public class DistributedQuery<K,V>
extends Object

Default class to query a state storeName either locally or remotely.

Constructor Summary

Constructors

Constructor	Description
DistributedQuery(RemoteQueryClient remoteQueryClient, PreparedQuery<K,V> query)	Creates a new DistributedQuery instance.

Method Summary

Modifier and Type	Method	Description
QueryResult<K,V>	query(KafkaStreamsContainer streams, Queried options)	Executes a state storeName query for specified arguments.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedQuery

public DistributedQuery(RemoteQueryClient remoteQueryClient,
                        PreparedQuery<K,V> query)

Creates a new DistributedQuery instance.

Method Detail

query

public QueryResult<K,V> query(KafkaStreamsContainer streams,
                                    Queried options)

Executes a state storeName query for specified arguments.

Parameters:

streams - the KafkaStreamsContainer instance on which to execute this query.

options - the Queried options.

Returns:

a QueryResult instance.