Package io.streamthoughts.azkarra.runtime.query

Class DistributedQueryExecutionDelegatee

java.lang.Object

io.streamthoughts.azkarra.runtime.query.DistributedQueryExecutionDelegatee

All Implemented Interfaces:

QueryExecutionDelegatee

public class DistributedQueryExecutionDelegatee
extends Object
implements QueryExecutionDelegatee

Constructor Summary

Constructors

Constructor	Description
DistributedQueryExecutionDelegatee(RemoteQueryCallFactory callFactory)	Creates a new DistributedQueryExecutionDelegatee instance.

Method Summary

Modifier and Type	Method	Description
<K,V> QueryResult<K,V>	execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)	Executed the provided QueryRequest with the specified QueryOptions and the KafkaStreamsContainer.
Class<? extends KafkaStreamsContainer>	supportedClass()	Gets the KafkaStreamsContainer class that is supported by this QueryExecutionDelegatee.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedQueryExecutionDelegatee

public DistributedQueryExecutionDelegatee(RemoteQueryCallFactory callFactory)

Creates a new DistributedQueryExecutionDelegatee instance.

Parameters:

callFactory - the RemoteQueryCallFactory.

Method Detail

supportedClass

public Class<? extends KafkaStreamsContainer> supportedClass()

Gets the KafkaStreamsContainer class that is supported by this QueryExecutionDelegatee.

Specified by:

supportedClass in interface QueryExecutionDelegatee

Returns:

the supported KafkaStreamsContainer class.

execute

public <K,V> QueryResult<K,V> execute(KafkaStreamsContainer container,
                                                  QueryRequest queryRequest,
                                                  QueryOptions queryOptions)

Executed the provided QueryRequest with the specified QueryOptions and the KafkaStreamsContainer.

Specified by:

execute in interface QueryExecutionDelegatee

Type Parameters:

K - the expected type for the record-key.

V - the expected type for the record-value.

Parameters:

container - the KafkaStreamsContainer object.

queryRequest - the QueryRequest to be execute.

queryOptions - the QueryOptions that should be used for executing the query.

Returns:

the QueryResult.