Table of Contents

Class KGroupedStream<K, V, TJVMK, TJVMV>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll

KNet extension of KGroupedStream<K, V>

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

Type Parameters

K
V
TJVMK

The JVM type of K

TJVMV

The JVM type of V

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

Methods

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

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

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

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

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

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

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

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

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA, TJVMVA>

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

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

arg2 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

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

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

Parameters

arg0 Initializer<VR, TJVMVR>

Initializer<VA>

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

Aggregator<K, V, VA>

arg2 Named

Named

arg3 Materialized<K, VR, TJVMK, TJVMVR>

Materialized<K, V, TJVMK, TJVMV>

Returns

KTable<K, VR, TJVMK, TJVMVR>

KTable<K, V, TJVMK, TJVMV>

Type Parameters

VR
TJVMVR

The JVM type of VR

Arg1objectSuperK

K

Arg1objectSuperV

V

Cogroup<VOut, TJVMVOut, Arg0objectSuperK, Arg0objectSuperV>(Aggregator<Arg0objectSuperK, Arg0objectSuperV, VOut, TJVMK, TJVMV, TJVMVOut>)

public CogroupedKStream<K, VOut, TJVMK, TJVMVOut> Cogroup<VOut, TJVMVOut, Arg0objectSuperK, Arg0objectSuperV>(Aggregator<Arg0objectSuperK, Arg0objectSuperV, VOut, TJVMK, TJVMV, TJVMVOut> arg0) where Arg0objectSuperK : K where Arg0objectSuperV : V

Parameters

arg0 Aggregator<Arg0objectSuperK, Arg0objectSuperV, VOut, TJVMK, TJVMV, TJVMVOut>

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

Returns

CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

CogroupedKStream<K, VOut, TJVMK, TJVMVOut>

Type Parameters

VOut
TJVMVOut

The JVM type of VOut

Arg0objectSuperK

K

Arg0objectSuperV

V

Count()

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

Returns

KTable<K, long, TJVMK, Long>

KTable

Count(CountingMaterialized<K, TJVMK>)

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

Parameters

arg0 CountingMaterialized<K, TJVMK>

CountingMaterialized<K, TJVMK>

Returns

KTable<K, long, TJVMK, Long>

KTable<K, V, TJVMK, TJVMV>

Count(Named)

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

Parameters

arg0 Named

Named

Returns

KTable<K, long, TJVMK, Long>

KTable<K, V, TJVMK, TJVMV>

Count(Named, CountingMaterialized<K, TJVMK>)

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

Parameters

arg0 Named

Named

arg1 CountingMaterialized<K, TJVMK>

CountingMaterialized<K, TJVMK>

Returns

KTable<K, long, TJVMK, Long>

KTable<K, V, TJVMK, TJVMV>

Reduce(Reducer<V, TJVMV>)

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

Parameters

arg0 Reducer<V, TJVMV>

Reducer<V, TJVMV>

Returns

KTable<K, V, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

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

public KTable<K, V, 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, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

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

public KTable<K, V, 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, TJVMK, TJVMV>

KTable<K, V, TJVMK, TJVMV>

WindowedBy(SessionWindows)

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

Parameters

arg0 SessionWindows

SessionWindows

Returns

SessionWindowedKStream<K, V, TJVMK, TJVMV>

SessionWindowedKStream<K, V, TJVMK, TJVMV>

WindowedBy(SlidingWindows)

public TimeWindowedKStream<K, V, TJVMK, TJVMV> WindowedBy(SlidingWindows arg0)

Parameters

arg0 SlidingWindows

SlidingWindows

Returns

TimeWindowedKStream<K, V, TJVMK, TJVMV>

TimeWindowedKStream<K, V, TJVMK, TJVMV>

WindowedBy<W>(Windows<W>)

public TimeWindowedKStream<K, V, TJVMK, TJVMV> WindowedBy<W>(Windows<W> arg0) where W : Window

Parameters

arg0 Windows<W>

Windows

Returns

TimeWindowedKStream<K, V, TJVMK, TJVMV>

TimeWindowedKStream<K, V, TJVMK, TJVMV>

Type Parameters

W

Window

Operators

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

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

Parameters

t KGroupedStream<K, V, TJVMK, TJVMV>

Returns

KGroupedStream<TJVMK, TJVMV>