Package io.streamthoughts.azkarra.api.query

Interface LocalExecutableQuery<K,V>

All Superinterfaces:

Query

All Known Subinterfaces:

LocalExecutableQueryWithKey<K1,K2,V>

All Known Implementing Classes:

BaseKeyedLocalStoreQuery, KeyValueCountQuery, KeyValueGetAllQuery, KeyValueGetQuery, KeyValueGetRangeQuery, LoggingFailureLocalExecutableQuery, SessionFetchKeyRangeQuery, SessionFetchQuery, TimestampedKeyValueGetAllQuery, TimestampedKeyValueGetQuery, TimestampedKeyValueGetRangeQuery, TimestampedWindowFetchAllQuery, TimestampedWindowFetchKeyRangeQuery, TimestampedWindowFetchQuery, TimestampedWindowFetchTimeRangeQuery, TimestampedWindowGetAllQuery, WindowFetchAllQuery, WindowFetchKeyRangeQuery, WindowFetchQuery, WindowFetchTimeRangeQuery, WindowGetAllQuery

public interface LocalExecutableQuery<K,V>
extends Query

Default interface to execute a local state storeName.

Field Summary

Fields

Modifier and Type	Field	Description
static int	NO_LIMIT

Method Summary

Modifier and Type	Method	Description
default Try<List<KV<K,V>>>	execute(LocalStoreAccessProvider provider)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
static <K,V> List<KV<K,V>>	toKeyValueAndTimestampListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>> it, long limit)
static <K,V> List<KV<K,V>>	toKeyValueListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,V> it, long limit)

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

getParams, getStoreName, getStoreOperation, getStoreType

Field Detail

NO_LIMIT

static final int NO_LIMIT

See Also:

Constant Field Values

Method Detail

execute

default Try<List<KV<K,V>>> execute(LocalStoreAccessProvider provider)

Executes this query to the specified KafkaStreams application.

Parameters:

provider - the LocalStoreAccessProvider instance.

execute

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

Executes this query to the specified KafkaStreams application.

Parameters:

provider - the KafkaStreamsContainer instance.

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

toKeyValueListAndClose

static <K,V> List<KV<K,V>> toKeyValueListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,V> it,
                                                              long limit)

toKeyValueAndTimestampListAndClose

static <K,V> List<KV<K,V>> toKeyValueAndTimestampListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>> it,
                                                                          long limit)