Table of Contents

Class SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll
public class SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K
V
TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance
SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
Implements
Inherited Members

Methods

Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV>, Merger<Arg1objectSuperK, V, TJVMK, TJVMV>)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV> arg0, Merger<Arg1objectSuperK, V, TJVMK, TJVMV> arg1) where Arg1objectSuperK : K

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Merger<Arg1objectSuperK, V, TJVMK, TJVMV>

Merger

Returns

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

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg1objectSuperK

K

Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV>, Merger<Arg1objectSuperK, V, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV> arg0, Merger<Arg1objectSuperK, V, TJVMK, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2) where Arg1objectSuperK : K

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Merger<Arg1objectSuperK, V, TJVMK, TJVMV>

Merger

arg2 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

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

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg1objectSuperK

K

Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV>, Merger<Arg1objectSuperK, V, TJVMK, TJVMV>, Named)

public KTable<K, V, Windowed<TJVMK>, TJVMV> Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV> arg0, Merger<Arg1objectSuperK, V, TJVMK, TJVMV> arg1, Named arg2) where Arg1objectSuperK : K

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Merger<Arg1objectSuperK, V, TJVMK, TJVMV>

Merger

arg2 Named

Named

Returns

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

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg1objectSuperK

K

Aggregate<Arg1objectSuperK>(Initializer<V, TJVMV>, Merger<Arg1objectSuperK, V, TJVMK, TJVMV>, Named, Materialized<K, V, TJVMK, TJVMV>)

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

Parameters

arg0 Initializer<V, TJVMV>

Initializer<VA, TJVMVA>

arg1 Merger<Arg1objectSuperK, V, TJVMK, TJVMV>

Merger

arg2 Named

Named

arg3 Materialized<K, V, TJVMK, TJVMV>

Materialized<K, V, TJVMK, TJVMV>

Returns

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

KTable<K, V, TJVMK, TJVMV>

Type Parameters

Arg1objectSuperK

K

Operators

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

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

Parameters

t SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>

Returns

SessionWindowedCogroupedKStream<TJVMK, TJVMV>