Table of Contents

Class Stores

Namespace
Org.Apache.Kafka.Streams.State
Assembly
MASES.KNet.dll
public class Stores : JVMBridgeBase<Stores>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<Stores>
Stores
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<Stores>.IsAssignableFrom(IJavaType)
JVMBridgeBase<Stores>.IsAssignableFrom<T>()
JVMBridgeBase<Stores>.Execute<T>(params T[])
JVMBridgeBase<Stores>.DynBridgeClazz
JVMBridgeBase<Stores>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

Stores()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public Stores()

Stores(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public Stores(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

InMemoryKeyValueStore(String)

public static KeyValueBytesStoreSupplier InMemoryKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

InMemorySessionStore(String, Duration)

public static SessionBytesStoreSupplier InMemorySessionStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

SessionBytesStoreSupplier

SessionBytesStoreSupplier

InMemoryWindowStore(String, Duration, Duration, bool)

public static WindowBytesStoreSupplier InMemoryWindowStore(String arg0, Duration arg1, Duration arg2, bool arg3)

Parameters

arg0 String

String

arg1 Duration

Duration

arg2 Duration

Duration

arg3 bool

bool

Returns

WindowBytesStoreSupplier

WindowBytesStoreSupplier

Exceptions

IllegalArgumentException

KeyValueStoreBuilder<K, V>(KeyValueBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<KeyValueStore<K, V>> KeyValueStoreBuilder<K, V>(KeyValueBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<KeyValueStore<K, V>>

StoreBuilder

Type Parameters

K
V

LruMap(String, int)

public static KeyValueBytesStoreSupplier LruMap(String arg0, int arg1)

Parameters

arg0 String

String

arg1 int

int

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentKeyValueStore(String)

public static KeyValueBytesStoreSupplier PersistentKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentSessionStore(String, Duration)

public static SessionBytesStoreSupplier PersistentSessionStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

SessionBytesStoreSupplier

SessionBytesStoreSupplier

PersistentTimestampedKeyValueStore(String)

public static KeyValueBytesStoreSupplier PersistentTimestampedKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentTimestampedWindowStore(String, Duration, Duration, bool)

public static WindowBytesStoreSupplier PersistentTimestampedWindowStore(String arg0, Duration arg1, Duration arg2, bool arg3)

Parameters

arg0 String

String

arg1 Duration

Duration

arg2 Duration

Duration

arg3 bool

bool

Returns

WindowBytesStoreSupplier

WindowBytesStoreSupplier

Exceptions

IllegalArgumentException

PersistentVersionedKeyValueStore(String, Duration)

public static VersionedBytesStoreSupplier PersistentVersionedKeyValueStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

VersionedBytesStoreSupplier

VersionedBytesStoreSupplier

PersistentVersionedKeyValueStore(String, Duration, Duration)

public static VersionedBytesStoreSupplier PersistentVersionedKeyValueStore(String arg0, Duration arg1, Duration arg2)

Parameters

arg0 String

String

arg1 Duration

Duration

arg2 Duration

Duration

Returns

VersionedBytesStoreSupplier

VersionedBytesStoreSupplier

PersistentWindowStore(String, Duration, Duration, bool)

public static WindowBytesStoreSupplier PersistentWindowStore(String arg0, Duration arg1, Duration arg2, bool arg3)

Parameters

arg0 String

String

arg1 Duration

Duration

arg2 Duration

Duration

arg3 bool

bool

Returns

WindowBytesStoreSupplier

WindowBytesStoreSupplier

Exceptions

IllegalArgumentException

SessionStoreBuilder<K, V>(SessionBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<SessionStore<K, V>> SessionStoreBuilder<K, V>(SessionBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 SessionBytesStoreSupplier

SessionBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<SessionStore<K, V>>

StoreBuilder

Type Parameters

K
V

TimestampedKeyValueStoreBuilder<K, V>(KeyValueBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<TimestampedKeyValueStore<K, V>> TimestampedKeyValueStoreBuilder<K, V>(KeyValueBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<TimestampedKeyValueStore<K, V>>

StoreBuilder

Type Parameters

K
V

TimestampedWindowStoreBuilder<K, V>(WindowBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<TimestampedWindowStore<K, V>> TimestampedWindowStoreBuilder<K, V>(WindowBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<TimestampedWindowStore<K, V>>

StoreBuilder

Type Parameters

K
V

VersionedKeyValueStoreBuilder<K, V>(VersionedBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<VersionedKeyValueStore<K, V>> VersionedKeyValueStoreBuilder<K, V>(VersionedBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 VersionedBytesStoreSupplier

VersionedBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<VersionedKeyValueStore<K, V>>

StoreBuilder

Type Parameters

K
V

WindowStoreBuilder<K, V>(WindowBytesStoreSupplier, Serde<K>, Serde<V>)

public static StoreBuilder<WindowStore<K, V>> WindowStoreBuilder<K, V>(WindowBytesStoreSupplier arg0, Serde<K> arg1, Serde<V> arg2)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

arg1 Serde<K>

Serde

arg2 Serde<V>

Serde

Returns

StoreBuilder<WindowStore<K, V>>

StoreBuilder

Type Parameters

K
V