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

Class TimestampedWindowQueryBuilder

java.lang.Object

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

io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder

All Implemented Interfaces:

QueryOperationBuilder

public class TimestampedWindowQueryBuilder
extends WindowQueryBuilder

Field Summary

Fields inherited from class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder

INVALID_TIME_ERROR, QUERY_PARAM_KEY, QUERY_PARAM_KEY_FROM, QUERY_PARAM_KEY_TO, QUERY_PARAM_TIME, QUERY_PARAM_TIME_FROM, QUERY_PARAM_TIME_TO, 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()

Methods inherited from class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder

operation

Methods inherited from class java.lang.Object

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

Method Detail

fetch

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

Overrides:

fetch in class WindowQueryBuilder

fetchKeyRange

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

Overrides:

fetchKeyRange in class WindowQueryBuilder

fetchTimeRange

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

Overrides:

fetchTimeRange in class WindowQueryBuilder

fetchAll

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

Overrides:

fetchAll in class WindowQueryBuilder

all

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

Overrides:

all in class WindowQueryBuilder