Class Materialized<K, V, TJVMK, TJVMV, TContainer>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet base extension of Materialized<K, V, S>

public abstract class Materialized<K, V, TJVMK, TJVMV, TContainer> : IGenericSerDesFactoryApplier, IKNetMaterialized<TJVMK, TJVMV> where TContainer : class, new()

Type Parameters

K

Key type

V

Value type

TJVMK

Key JVM type

TJVMV

Value JVM type

TContainer

The implementing class, see Materialized<K, V, TJVMK> or CountingMaterialized<K, TJVMK>

Inheritance

object

Materialized<K, V, TJVMK, TJVMV, TContainer>

Implements

IGenericSerDesFactoryApplier

IKNetMaterialized<TJVMK, TJVMV>

Derived

CountingMaterialized<K, TJVMK>

Materialized<K, V, TJVMK>

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

Methods

As(StoreType)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#as(org.apache.kafka.streams.kstream.Materialized.StoreType)

public static TContainer As(Materialized.StoreType arg0)

Parameters

arg0 Materialized.StoreType

Materialized.StoreType

Returns

TContainer

TContainer

As(KeyValueBytesStoreSupplier)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#as(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier)

public static TContainer As(KeyValueBytesStoreSupplier arg0)

Parameters

arg0 KeyValueBytesStoreSupplier

KeyValueBytesStoreSupplier

Returns

TContainer

TContainer

As(SessionBytesStoreSupplier)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#as(org.apache.kafka.streams.state.SessionBytesStoreSupplier)

public static TContainer As(SessionBytesStoreSupplier arg0)

Parameters

arg0 SessionBytesStoreSupplier

SessionBytesStoreSupplier

Returns

TContainer

TContainer

As(WindowBytesStoreSupplier)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#as(org.apache.kafka.streams.state.WindowBytesStoreSupplier)

public static TContainer As(WindowBytesStoreSupplier arg0)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

Returns

TContainer

TContainer

As(string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#as(java.lang.String)

public static TContainer As(string arg0)

Parameters

arg0 string

string

Returns

TContainer

TContainer

WithCachingDisabled()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withCachingDisabled()

public TContainer WithCachingDisabled()

Returns

TContainer

TContainer

WithCachingEnabled()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withCachingEnabled()

public TContainer WithCachingEnabled()

Returns

TContainer

TContainer

WithKeySerde(ISerDes<K, TJVMK>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withKeySerde(org.apache.kafka.common.serialization.Serde)

public TContainer WithKeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

TContainer

TContainer

WithLoggingDisabled()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withLoggingDisabled()

public TContainer WithLoggingDisabled()

Returns

TContainer

TContainer

WithLoggingEnabled(Map<String, String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withLoggingEnabled(java.util.Map)

public TContainer WithLoggingEnabled(Map<String, String> arg0)

Parameters

arg0 Map<String, String>

Map

Returns

TContainer

TContainer

WithRetention(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withRetention(java.time.Duration)

public TContainer WithRetention(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

TContainer

TContainer

Exceptions

IllegalArgumentException

WithStoreType(StoreType)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/Materialized.html#withStoreType(org.apache.kafka.streams.kstream.Materialized.StoreType)

public TContainer WithStoreType(Materialized.StoreType arg0)

Parameters

arg0 Materialized.StoreType

Materialized.StoreType

Returns

TContainer

TContainer

Exceptions

IllegalArgumentException

Operators

implicit operator Materialized<TJVMK, TJVMV, KeyValueStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer>)

Converter from Materialized<K, V, TJVMK, TJVMV, TContainer> to Materialized<K, V, S>

public static implicit operator Materialized<TJVMK, TJVMV, KeyValueStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer> t)

Parameters

t Materialized<K, V, TJVMK, TJVMV, TContainer>

Returns

Materialized<TJVMK, TJVMV, KeyValueStore<Bytes, byte[]>>

implicit operator Materialized<TJVMK, TJVMV, SessionStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer>)

Converter from Materialized<K, V, TJVMK, TJVMV, TContainer> to Materialized<K, V, S>

public static implicit operator Materialized<TJVMK, TJVMV, SessionStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer> t)

Parameters

t Materialized<K, V, TJVMK, TJVMV, TContainer>

Returns

Materialized<TJVMK, TJVMV, SessionStore<Bytes, byte[]>>

implicit operator Materialized<TJVMK, TJVMV, WindowStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer>)

Converter from Materialized<K, V, TJVMK, TJVMV, TContainer> to Materialized<K, V, S>

public static implicit operator Materialized<TJVMK, TJVMV, WindowStore<Bytes, byte[]>>(Materialized<K, V, TJVMK, TJVMV, TContainer> t)

Parameters

t Materialized<K, V, TJVMK, TJVMV, TContainer>

Returns

Materialized<TJVMK, TJVMV, WindowStore<Bytes, byte[]>>