DistributedQuery (Azkarra Streams 0.5.0 API)

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

All Methods Instance Methods Concrete Methods
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.