Interface QueryExecutionDelegatee
-
- All Known Implementing Classes:
DistributedQueryExecutionDelegatee
public interface QueryExecutionDelegatee
AQueryExecutionDelegatee
is used to plug a specific strategy to execute a state store query.- See Also:
DefaultInteractiveQueryService
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <K,V>
QueryResult<K,V>execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
Class<? extends KafkaStreamsContainer>
supportedClass()
Gets theKafkaStreamsContainer
class that is supported by thisQueryExecutionDelegatee
.
-
-
-
Method Detail
-
supportedClass
Class<? extends KafkaStreamsContainer> supportedClass()
Gets theKafkaStreamsContainer
class that is supported by thisQueryExecutionDelegatee
.- Returns:
- the supported
KafkaStreamsContainer
class.
-
execute
<K,V> QueryResult<K,V> execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
- Type Parameters:
K
- the expected type for the record-key.V
- the expected type for the record-value.- Parameters:
container
- theKafkaStreamsContainer
object.queryRequest
- theQueryRequest
to be execute.queryOptions
- theQueryOptions
that should be used for executing the query.- Returns:
- the
QueryResult
.
-
-