Package io.streamthoughts.azkarra.runtime.query

Class DefaultInteractiveQueryService

java.lang.Object

io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService

All Implemented Interfaces:

InteractiveQueryService

public class DefaultInteractiveQueryService
extends Object
implements InteractiveQueryService

A DefaultInteractiveQueryService is used to execute a query request. The query execution can be delegate to a QueryExecutionDelegatee.

Constructor Summary

Constructors

Constructor	Description
DefaultInteractiveQueryService(AzkarraStreamsService service)	Creates a new DefaultInteractiveQueryService instance.
DefaultInteractiveQueryService(AzkarraStreamsService service, List<QueryExecutionDelegatee> executors)	Creates a new DefaultInteractiveQueryService instance.

Method Summary

Modifier and Type	Method	Description
<K,V> QueryResult<K,V>	execute(String applicationId, QueryRequest queryRequest, QueryOptions queryOptions)	Executes an interactive query for the specified streams application.
void	registerQueryExecutionDelegatee(QueryExecutionDelegatee delegatee)	Registers a new QueryExecutionDelegatee instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultInteractiveQueryService

public DefaultInteractiveQueryService(AzkarraStreamsService service)

Creates a new DefaultInteractiveQueryService instance.

Parameters:

service - the AzkarraStreamsService instance.

DefaultInteractiveQueryService

public DefaultInteractiveQueryService(AzkarraStreamsService service,
                                      List<QueryExecutionDelegatee> executors)

Creates a new DefaultInteractiveQueryService instance.

Parameters:

service - the AzkarraStreamsService instance.

Method Detail

execute

public <K,V> QueryResult<K,V> execute(String applicationId,
                                                  QueryRequest queryRequest,
                                                  QueryOptions queryOptions)

Executes an interactive query for the specified streams application.

Specified by:

execute in interface InteractiveQueryService

Parameters:

applicationId - the application.id of the Kafka Streams to query.

queryRequest - the query object to be executed.

queryOptions - the options of the query.

Returns:

the QueryResult instance.

registerQueryExecutionDelegatee

public void registerQueryExecutionDelegatee(QueryExecutionDelegatee delegatee)

Registers a new QueryExecutionDelegatee instance.

Parameters:

delegatee - the QueryExecutionDelegatee to register.