Class ManagedStore<TStore>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

Base class for stores managed from KNet

public class ManagedStore<TStore> : IManagedStore<TStore>, IGenericSerDesFactoryApplier

Type Parameters

TStore

The Apache Kafka store type

Inheritance

object

ManagedStore<TStore>

Implements

IManagedStore<TStore>

IGenericSerDesFactoryApplier

Derived

ReadOnlyKeyValueStore<K, V, TJVMK, TJVMV>

ReadOnlySessionStore<K, AGG, TJVMK, TJVMAGG>

ReadOnlyWindowStore<K, V, TJVMK, TJVMV>

TimestampedKeyValueStore<K, V, TJVMK, TJVMV>

TimestampedWindowStore<K, V, TJVMK, TJVMV>

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

Store

Returns the current TStore instance

protected TStore Store { get; }

Property Value

TStore