Class Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of Joined<K, V, VO>

public class Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> : IGenericSerDesFactoryApplier

Type Parameters

K

V

VO

TJVMK

The JVM type of K

TJVMV

The JVM type of V

TJVMVO

The JVM type of VO

Inheritance

object

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Implements

IGenericSerDesFactoryApplier

Derived

Joined<K, V, VO>

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

GracePeriod

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Joined.html#gracePeriod--

public TimeSpan GracePeriod { get; }

Property Value

TimeSpan

TimeSpan

Methods

As(string)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Joined.html#as-java.lang.String-

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> As(string arg0)

Parameters

arg0 string

string

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

KeySerde(ISerDes<K, TJVMK>)

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

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> KeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

OtherValueSerde(ISerDes<VO, TJVMVO>)

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

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> OtherValueSerde(ISerDes<VO, TJVMVO> arg0)

Parameters

arg0 ISerDes<VO, TJVMVO>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

ValueSerde(ISerDes<V, TJVMV>)

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

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> ValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

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

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

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1, ISerDes<VO, TJVMVO> arg2)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

arg2 ISerDes<VO, TJVMVO>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>, ISerDes<VO, TJVMVO>, string)

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

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1, ISerDes<VO, TJVMVO> arg2, string arg3)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

arg2 ISerDes<VO, TJVMVO>

ISerDes<T, TJVMT>

arg3 string

string

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>, ISerDes<VO, TJVMVO>, string, TimeSpan)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Joined.html#with-org.apache.kafka.common.serialization.Serde-org.apache.kafka.common.serialization.Serde-org.apache.kafka.common.serialization.Serde-java.lang.String-java.time.Duration-

public static Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1, ISerDes<VO, TJVMVO> arg2, string arg3, TimeSpan arg4)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

arg2 ISerDes<VO, TJVMVO>

ISerDes<T, TJVMT>

arg3 string

string

arg4 TimeSpan

TimeSpan

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

WithGracePeriod(TimeSpan)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/Joined.html#withGracePeriod-java.time.Duration-

public Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> WithGracePeriod(TimeSpan arg0)

Parameters

arg0 TimeSpan

TimeSpan

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

WithKeySerde(ISerDes<K, TJVMK>)

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

public Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> WithKeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

WithOtherValueSerde(ISerDes<VO, TJVMVO>)

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

public Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> WithOtherValueSerde(ISerDes<VO, TJVMVO> arg0)

Parameters

arg0 ISerDes<VO, TJVMVO>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

WithValueSerde(ISerDes<V, TJVMV>)

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

public Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> WithValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Operators

implicit operator Joined<TJVMK, TJVMV, TJVMVO>(Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>)

Converter from Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> to Joined<K, V, VO>

public static implicit operator Joined<TJVMK, TJVMV, TJVMVO>(Joined<K, V, VO, TJVMK, TJVMV, TJVMVO> t)

Parameters

t Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>

Returns

Joined<TJVMK, TJVMV, TJVMVO>