Table of Contents

Class ReadOnlyWindowStore<K, V, TJVMK, TJVMV>

Namespace
MASES.KNet.Streams.State
Assembly
MASES.KNet.dll

KNet implementation of ReadOnlyWindowStore<K, V>

public class ReadOnlyWindowStore<K, V, TJVMK, TJVMV> : ManagedStore<ReadOnlyWindowStore<TJVMK, TJVMV>>, IManagedStore<ReadOnlyWindowStore<TJVMK, TJVMV>>, IGenericSerDesFactoryApplier

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance
ReadOnlyWindowStore<K, V, TJVMK, TJVMV>
Implements
Derived
Inherited Members

Properties

BackwardAll

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardAll { get; }

Property Value

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Methods

All()

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> All()

Returns

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

BackwardFetch(K, Instant, Instant)

public virtual WindowStoreIterator<V, TJVMV> BackwardFetch(K arg0, Instant arg1, Instant arg2)

Parameters

arg0 K

K

arg1 Instant

Instant

arg2 Instant

Instant

Returns

WindowStoreIterator<V, TJVMV>

WindowStoreIterator<V, TJVMV>

Exceptions

IllegalArgumentException

BackwardFetch(K, K, Instant, Instant)

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardFetch(K arg0, K arg1, Instant arg2, Instant arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 Instant

Instant

arg3 Instant

Instant

Returns

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Exceptions

IllegalArgumentException

BackwardFetchAll(Instant, Instant)

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> BackwardFetchAll(Instant arg0, Instant arg1)

Parameters

arg0 Instant

Instant

arg1 Instant

Instant

Returns

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator

Exceptions

IllegalArgumentException

Fetch(K, Instant, Instant)

public virtual WindowStoreIterator<V, TJVMV> Fetch(K arg0, Instant arg1, Instant arg2)

Parameters

arg0 K

K

arg1 Instant

Instant

arg2 Instant

Instant

Returns

WindowStoreIterator<V, TJVMV>

WindowStoreIterator<V, TJVMV>

Exceptions

IllegalArgumentException

Fetch(K, long)

public virtual V Fetch(K arg0, long arg1)

Parameters

arg0 K

K

arg1 long

long

Returns

V

V

Fetch(K, K, Instant, Instant)

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> Fetch(K arg0, K arg1, Instant arg2, Instant arg3)

Parameters

arg0 K

K

arg1 K

K

arg2 Instant

Instant

arg3 Instant

Instant

Returns

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

Exceptions

IllegalArgumentException

FetchAll(Instant, Instant)

public virtual WindowedKeyValueIterator<K, V, TJVMK, TJVMV> FetchAll(Instant arg0, Instant arg1)

Parameters

arg0 Instant

Instant

arg1 Instant

Instant

Returns

WindowedKeyValueIterator<K, V, TJVMK, TJVMV>

KeyValueIterator

Exceptions

IllegalArgumentException