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
protected String	store

Method Summary

Modifier and Type	Method	Description
<K,V> LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>	all()
<K,V> LocalPreparedQuery<K,V>	fetch()
<K,V> LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetchAll()
<K,V> LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>	fetchKeyRange()
<K,V> LocalPreparedQuery<Long,V>	fetchTimeRange()
LocalPreparedQuery<?,?>	prepare(StoreOperation operation)

Methods inherited from class java.lang.Object

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

Field Detail

INVALID_TIME_ERROR

public static final Error INVALID_TIME_ERROR

store

protected final String store

Method Detail

prepare

public LocalPreparedQuery<?,?> prepare(StoreOperation operation)

Specified by:

prepare in interface QueryOperationBuilder

fetch

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

fetchKeyRange

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

fetchTimeRange

public <K,V> LocalPreparedQuery<Long,V> fetchTimeRange()

fetchAll

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

all

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