Class BranchedKStream<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of BranchedKStream<K, V>

public class BranchedKStream<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

BranchedKStream<K, V, TJVMK, TJVMV>

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Branch<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/BranchedKStream.html#branch-org.apache.kafka.streams.kstream.Predicate-

public BranchedKStream<K, V, TJVMK, TJVMV> Branch<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

Returns

BranchedKStream<K, V, TJVMK, TJVMV>

BranchedKStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

Branch<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>, Branched<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/BranchedKStream.html#branch-org.apache.kafka.streams.kstream.Predicate-org.apache.kafka.streams.kstream.Branched-

public BranchedKStream<K, V, TJVMK, TJVMV> Branch<Arg0objectSuperK, Arg0objectSuperV>(Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV> arg0, Branched<K, V, TJVMK, TJVMV> arg1) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Predicate<Arg0objectSuperK, Arg0objectSuperV, TJVMK, TJVMV>

Predicate<K, V, TJVMK, TJVMV>

arg1 Branched<K, V, TJVMK, TJVMV>

Branched<K, V, TJVMK, TJVMV>

Returns

BranchedKStream<K, V, TJVMK, TJVMV>

BranchedKStream

Type Parameters

Arg0objectSuperK

K

Arg0objectSuperV

V

DefaultBranch()

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

public IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>> DefaultBranch()

Returns

IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>>

IReadOnlyDictionary<TKey, TValue>

DefaultBranch(Branched<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/BranchedKStream.html#defaultBranch-org.apache.kafka.streams.kstream.Branched-

public IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>> DefaultBranch(Branched<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 Branched<K, V, TJVMK, TJVMV>

Branched<K, V, TJVMK, TJVMV>

Returns

IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>>

Map

NoDefaultBranch()

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

public IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>> NoDefaultBranch()

Returns

IReadOnlyDictionary<string, KStream<K, V, TJVMK, TJVMV>>

Map

Operators

implicit operator BranchedKStream<TJVMK, TJVMV>(BranchedKStream<K, V, TJVMK, TJVMV>)

Converter from BranchedKStream<K, V, TJVMK, TJVMV> to BranchedKStream<K, V>

public static implicit operator BranchedKStream<TJVMK, TJVMV>(BranchedKStream<K, V, TJVMK, TJVMV> t)

Parameters

t BranchedKStream<K, V, TJVMK, TJVMV>

Returns

BranchedKStream<TJVMK, TJVMV>