Package io.streamthoughts.azkarra.api.query

Interface QueryCall.QueryCallFactory

All Known Subinterfaces:

KafkaStreamsContainer, QueryableKafkaStreams

All Known Implementing Classes:

LocalKafkaStreamsContainer

Enclosing interface:

QueryCall<K,V>

public static interface QueryCall.QueryCallFactory

A QueryCallFactory is used to create new QueryCall.

Method Summary

Modifier and Type	Method	Description
<K,V> QueryCall<K,V>	newQueryCall(QueryRequest request)	Creates a new QueryCall for specified QueryRequest.

Method Detail

newQueryCall

<K,V> QueryCall<K,V> newQueryCall(QueryRequest request)
                                       throws InvalidQueryException

Creates a new QueryCall for specified QueryRequest.

Type Parameters:

K - the expected type for record-key.

V - the expected type for record-value.

Parameters:

request - the query.

Returns:

a new QueryCall object.

Throws:

InvalidQueryException - if the given request is invalid.