Class Stores

Namespace

Org.Apache.Kafka.Streams.State

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html

public class Stores : JVMBridgeBase<Stores>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<Stores>

Stores

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

Stores()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#%3Cinit%3E()

public Stores()

Stores(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Stores(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

CreatePoolableInstance()

HPA initializer for Stores()

public static Stores CreatePoolableInstance()

Returns

Stores

InMemoryKeyValueStore(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#inMemoryKeyValueStore(java.lang.String)

public static KeyValueBytesStoreSupplier InMemoryKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

InMemorySessionStore(String, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#inMemorySessionStore(java.lang.String,java.time.Duration)

public static SessionBytesStoreSupplier InMemorySessionStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

SessionBytesStoreSupplier

SessionBytesStoreSupplier

InMemoryWindowStore(String, Duration, Duration, bool)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#inMemoryWindowStore(java.lang.String,java.time.Duration,java.time.Duration,boolean)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#keyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#lruMap(java.lang.String,int)

public static KeyValueBytesStoreSupplier LruMap(String arg0, int arg1)

Parameters

arg0 String

String

arg1 int

int

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentKeyValueStore(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentKeyValueStore(java.lang.String)

public static KeyValueBytesStoreSupplier PersistentKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentSessionStore(String, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentSessionStore(java.lang.String,java.time.Duration)

public static SessionBytesStoreSupplier PersistentSessionStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

SessionBytesStoreSupplier

SessionBytesStoreSupplier

PersistentTimestampedKeyValueStore(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentTimestampedKeyValueStore(java.lang.String)

public static KeyValueBytesStoreSupplier PersistentTimestampedKeyValueStore(String arg0)

Parameters

arg0 String

String

Returns

KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

PersistentTimestampedWindowStore(String, Duration, Duration, bool)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentTimestampedWindowStore(java.lang.String,java.time.Duration,java.time.Duration,boolean)

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)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentVersionedKeyValueStore(java.lang.String,java.time.Duration)

public static VersionedBytesStoreSupplier PersistentVersionedKeyValueStore(String arg0, Duration arg1)

Parameters

arg0 String

String

arg1 Duration

Duration

Returns

VersionedBytesStoreSupplier

VersionedBytesStoreSupplier

PersistentVersionedKeyValueStore(String, Duration, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentVersionedKeyValueStore(java.lang.String,java.time.Duration,java.time.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)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#persistentWindowStore(java.lang.String,java.time.Duration,java.time.Duration,boolean)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#sessionStoreBuilder(org.apache.kafka.streams.state.SessionBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#timestampedKeyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#timestampedWindowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#versionedKeyValueStoreBuilder(org.apache.kafka.streams.state.VersionedBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/state/Stores.html#windowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

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