Package io.streamthoughts.azkarra.api.query

Class LoggingFailureLocalExecutableQuery<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.DecorateQuery<LocalExecutableQuery<K,V>>

io.streamthoughts.azkarra.api.query.LoggingFailureLocalExecutableQuery<K,V>

All Implemented Interfaces:

LocalExecutableQuery<K,V>, Query

public class LoggingFailureLocalExecutableQuery<K,V>
extends DecorateQuery<LocalExecutableQuery<K,V>>
implements LocalExecutableQuery<K,V>

Field Summary

Fields inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

query

Fields inherited from interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery

NO_LIMIT

Constructor Summary

Constructors

Constructor	Description
LoggingFailureLocalExecutableQuery(LocalExecutableQuery<K,V> query)	Creates a new LoggingFailureLocalExecutableQuery instance.

Method Summary

Modifier and Type	Method	Description
Try<List<KV<K,V>>>	execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.

Methods inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

equals, getParams, getStoreName, getStoreOperation, getStoreType, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery

execute

Methods inherited from interface io.streamthoughts.azkarra.api.query.Query

getParams, getStoreName, getStoreOperation, getStoreType

Constructor Detail

LoggingFailureLocalExecutableQuery

public LoggingFailureLocalExecutableQuery(LocalExecutableQuery<K,V> query)

Creates a new LoggingFailureLocalExecutableQuery instance.

Parameters:

query - the LocalExecutableQuery.

Method Detail

execute

public Try<List<KV<K,V>>> execute(LocalStoreAccessProvider provider,
                                        long limit)

Executes this query to the specified KafkaStreams application.

Specified by:

execute in interface LocalExecutableQuery<K,V>

Parameters:

provider - the KafkaStreamsContainer instance.

limit - the maximum number of records the result should be limited to (-1 means no limit).