Class SessionWindowedKStream<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of SessionWindowedKStream<K, V>

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

Type Parameters

K

V

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

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

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Merger-

public KTable<K, VR, Windowed<TJVMK>, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR> arg2) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>

Merger<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, Windowed<TJVMK>, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Merger-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, VR, Windowed<TJVMK>, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR> arg2, Materialized<K, VR, TJVMK, TJVMVR> arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>

Merger<K, V, TJVMK, TJVMV>

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, Windowed<TJVMK>, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Merger-org.apache.kafka.streams.kstream.Named-

public KTable<K, VR, Windowed<TJVMK>, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR> arg2, Named arg3) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>

Merger<K, V, TJVMK, TJVMV>

arg3 Named

Named

Returns

KTable<K, VR, Windowed<TJVMK>, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR>, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>, Named, Materialized<K, VR, TJVMK, TJVMVR>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Merger-org.apache.kafka.streams.kstream.Named-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, VR, Windowed<TJVMK>, TJVMVR> Aggregate<VR, TJVMVR, Arg1objectSuperK, Arg1objectSuperV, Arg2objectSuperK>(Initializer<VR, TJVMVR> arg0, Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR> arg1, Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR> arg2, Named arg3, Materialized<K, VR, TJVMK, TJVMVR> arg4) where Arg1objectSuperK : K where Arg1objectSuperV : V where Arg2objectSuperK : K

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

arg1 Aggregator<Arg1objectSuperK, Arg1objectSuperV, VR, TJVMK, TJVMV, TJVMVR>

Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>

arg2 Merger<Arg2objectSuperK, VR, TJVMK, TJVMVR>

Merger<K, V, TJVMK, TJVMV>

arg3 Named

Named

arg4 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, Windowed<TJVMK>, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR

TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Arg2objectSuperK

K

Count()

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

public KTable<K, long, Windowed<TJVMK>, Long> Count()

Returns

KTable<K, long, Windowed<TJVMK>, Long>

KTable

Count(Materialized<K, long, TJVMK, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#count-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, long, Windowed<TJVMK>, Long> Count(Materialized<K, long, TJVMK, Long> arg0)

Parameters

arg0 Materialized<K, long, TJVMK, Long>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, long, Windowed<TJVMK>, Long>

KTable<K, V, TJVMK, TJVMV>

Count(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#count-org.apache.kafka.streams.kstream.Named-

public KTable<K, long, Windowed<TJVMK>, Long> Count(Named arg0)

Parameters

arg0 Named

Named

Returns

KTable<K, long, Windowed<TJVMK>, Long>

KTable<K, V, TJVMK, TJVMV>

Count(Named, Materialized<K, long, TJVMK, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#count-org.apache.kafka.streams.kstream.Named-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, long, Windowed<TJVMK>, Long> Count(Named arg0, Materialized<K, long, TJVMK, Long> arg1)

Parameters

arg0 Named

Named

arg1 Materialized<K, long, TJVMK, Long>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, long, Windowed<TJVMK>, Long>

KTable<K, V, TJVMK, TJVMV>

EmitStrategy(EmitStrategy)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#emitStrategy-org.apache.kafka.streams.kstream.EmitStrategy-

public SessionWindowedKStream<K, V, TJVMK, TJVMV> EmitStrategy(EmitStrategy arg0)

Parameters

arg0 EmitStrategy

EmitStrategy

Returns

SessionWindowedKStream<K, V, TJVMK, TJVMV>

SessionWindowedKStream<K, V, TJVMK, TJVMV>

Reduce(Reducer<V, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#reduce-Reducer{V, TJVMV}-

public KTable<K, V, Windowed<TJVMK>, TJVMV> Reduce(Reducer<V, TJVMV> arg0)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Reduce(Reducer<V, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#reduce-Reducer{V, TJVMV}-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, V, Windowed<TJVMK>, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Materialized<K, V, TJVMK, TJVMV> arg1)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Reduce(Reducer<V, TJVMV>, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#reduce-Reducer{V, TJVMV}-org.apache.kafka.streams.kstream.Named-

public KTable<K, V, Windowed<TJVMK>, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Named arg1)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Named

Named

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Reduce(Reducer<V, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/SessionWindowedKStream.html#reduce-Reducer{V, TJVMV}-org.apache.kafka.streams.kstream.Named-Materialized{K, V, TJVMK, TJVMV}-

public KTable<K, V, Windowed<TJVMK>, TJVMV> Reduce(Reducer<V, TJVMV> arg0, Named arg1, Materialized<K, V, TJVMK, TJVMV> arg2)

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

arg1 Named

Named

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, V, Windowed<TJVMK>, TJVMV>

KTable<K, V, TJVMK, TJVMV>

Operators

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

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

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

Parameters

t SessionWindowedKStream<K, V, TJVMK, TJVMV>

Returns

SessionWindowedKStream<TJVMK, TJVMV>