Class TimestampedWindowStore<K, V, TJVMK, TJVMV>
KNet implementation of ReadOnlyWindowStore<K, V>
public class TimestampedWindowStore<K, V, TJVMK, TJVMV> : ManagedStore<ReadOnlyWindowStore<TJVMK, ValueAndTimestamp<TJVMV>>>, IManagedStore<ReadOnlyWindowStore<TJVMK, ValueAndTimestamp<TJVMV>>>, IGenericSerDesFactoryApplierType Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
- Inheritance
-
TimestampedWindowStore<K, V, TJVMK, TJVMV>
- Implements
- Derived
- Inherited Members
Properties
BackwardAll
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardAll { get; }Property Value
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
Methods
All()
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> All()Returns
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
BackwardFetch(K, Instant, Instant)
public virtual TimestampedWindowStoreIterator<V, TJVMV> BackwardFetch(K arg0, Instant arg1, Instant arg2)Parameters
Returns
Exceptions
BackwardFetch(K, K, Instant, Instant)
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardFetch(K arg0, K arg1, Instant arg2, Instant arg3)Parameters
Returns
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
Exceptions
BackwardFetchAll(Instant, Instant)
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardFetchAll(Instant arg0, Instant arg1)Parameters
Returns
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
Exceptions
Fetch(K, Instant, Instant)
public virtual TimestampedWindowStoreIterator<V, TJVMV> Fetch(K arg0, Instant arg1, Instant arg2)Parameters
Returns
Exceptions
Fetch(K, long)
public virtual ValueAndTimestamp<V, TJVMV> Fetch(K arg0, long arg1)Parameters
Returns
- ValueAndTimestamp<V, TJVMV>
Fetch(K, K, Instant, Instant)
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> Fetch(K arg0, K arg1, Instant arg2, Instant arg3)Parameters
Returns
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
Exceptions
FetchAll(Instant, Instant)
public virtual TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV> FetchAll(Instant arg0, Instant arg1)Parameters
Returns
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>