Class Materialized<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of Materialized<K, V, TJVMK, TJVMV, TContainer>

public sealed class Materialized<K, V, TJVMK, TJVMV> : Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>, IGenericSerDesFactoryApplier, IKNetMaterialized<TJVMK, TJVMV>

Type Parameters

K

V

TJVMK

Key JVM type

TJVMV

Value JVM type

Inheritance

object

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

Materialized<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

IKNetMaterialized<TJVMK, TJVMV>

Inherited Members

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.As(string)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.As(Materialized.StoreType)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.As(KeyValueBytesStoreSupplier)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.As(SessionBytesStoreSupplier)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.As(WindowBytesStoreSupplier)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithCachingDisabled()

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithCachingEnabled()

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithKeySerde(ISerDes<K, TJVMK>)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithLoggingDisabled()

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithLoggingEnabled(Map<String, String>)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithRetention(Duration)

Materialized<K, V, TJVMK, TJVMV, Materialized<K, V, TJVMK, TJVMV>>.WithStoreType(Materialized.StoreType)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

Methods

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Materialized.html#with-org.apache.kafka.common.serialization.Serde-org.apache.kafka.common.serialization.Serde-

public static Materialized<K, V, TJVMK, TJVMV> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

WithValueSerde(ISerDes<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Materialized.html#withValueSerde-org.apache.kafka.common.serialization.Serde-

public Materialized<K, V, TJVMK, TJVMV> WithValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK>