Package io.streamthoughts.azkarra.api.query.internal

Class SessionQueryBuilder

java.lang.Object

io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder

All Implemented Interfaces:

QueryOperationBuilder

public class SessionQueryBuilder
extends Object
implements QueryOperationBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static String	QUERY_PARAM_KEY
static String	QUERY_PARAM_KEY_FROM
static String	QUERY_PARAM_KEY_TO

Method Summary

Modifier and Type	Method	Description
<K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetch()
<K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetchKeyRange()
Query	operation(StoreOperation operation)

Methods inherited from class java.lang.Object

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

Field Detail

QUERY_PARAM_KEY

public static final String QUERY_PARAM_KEY

See Also:

Constant Field Values

QUERY_PARAM_KEY_FROM

public static final String QUERY_PARAM_KEY_FROM

See Also:

Constant Field Values

QUERY_PARAM_KEY_TO

public static final String QUERY_PARAM_KEY_TO

See Also:

Constant Field Values

Method Detail

operation

public Query operation(StoreOperation operation)

Specified by:

operation in interface QueryOperationBuilder

fetch

public <K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V> fetch()

fetchKeyRange

public <K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V> fetchKeyRange()