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

Class WindowQueryBuilder

java.lang.Object

io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder

All Implemented Interfaces:

QueryOperationBuilder

Direct Known Subclasses:

TimestampedWindowQueryBuilder

public class WindowQueryBuilder
extends Object
implements QueryOperationBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static Error	INVALID_TIME_ERROR
static String	QUERY_PARAM_KEY
static String	QUERY_PARAM_KEY_FROM
static String	QUERY_PARAM_KEY_TO
static String	QUERY_PARAM_TIME
static String	QUERY_PARAM_TIME_FROM
static String	QUERY_PARAM_TIME_TO
protected String	storeName

Method Summary

Modifier and Type	Method	Description
<K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V>	all()
<K,V> Query<K,V>	fetch()
<K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetchAll()
<K,V> Query<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetchKeyRange()
<V> Query<Long,V>	fetchTimeRange()
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

QUERY_PARAM_TIME

public static final String QUERY_PARAM_TIME

See Also:

Constant Field Values

QUERY_PARAM_TIME_FROM

public static final String QUERY_PARAM_TIME_FROM

See Also:

Constant Field Values

QUERY_PARAM_TIME_TO

public static final String QUERY_PARAM_TIME_TO

See Also:

Constant Field Values

INVALID_TIME_ERROR

public static final Error INVALID_TIME_ERROR

storeName

protected final String storeName

Method Detail

operation

public Query operation(StoreOperation operation)

Specified by:

operation in interface QueryOperationBuilder

fetch

public <K,V> Query<K,V> fetch()

fetchKeyRange

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

fetchTimeRange

public <V> Query<Long,V> fetchTimeRange()

fetchAll

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

all

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