Class TimestampedWindowStoreWithHeaders<K, V>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet implementation of ReadOnlyWindowStore<K, V>

public class TimestampedWindowStoreWithHeaders<K, V> : TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>, IManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>, IDisposable, IGenericSerDesFactoryApplier

Type Parameters

K

The key type

V

The value type

Inheritance

object

ManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>

TimestampedWindowStoreWithHeaders<K, V>

Implements

IManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>

IDisposable

IGenericSerDesFactoryApplier

Inherited Members

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.All()

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.Fetch(K, K, Instant, Instant)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.FetchAll(Instant, Instant)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.Fetch(K, Instant, Instant)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.Fetch(K, long)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.BackwardAll()

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.BackwardFetch(K, K, Instant, Instant)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.BackwardFetchAll(Instant, Instant)

TimestampedWindowStoreWithHeaders<K, V, byte[], byte[]>.BackwardFetch(K, Instant, Instant)

ManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>.Store

ManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>.Factory

ManagedStore<ReadOnlyWindowStore<byte[], ValueTimestampHeaders<byte[]>>>.Dispose()