Table of Contents

Class CogroupedKStream

Namespace
Org.Apache.Kafka.Streams.Kstream
Assembly
MASES.KNet.dll
public class CogroupedKStream : JVMBridgeBase<CogroupedKStream>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<CogroupedKStream>
CogroupedKStream
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<CogroupedKStream>.IsAssignableFrom(IJavaType)
JVMBridgeBase<CogroupedKStream>.IsAssignableFrom<T>()
JVMBridgeBase<CogroupedKStream>.Execute<T>(params T[])
JVMBridgeBase<CogroupedKStream>.DynBridgeClazz
JVMBridgeBase<CogroupedKStream>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

CogroupedKStream()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("CogroupedKStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public CogroupedKStream()

CogroupedKStream(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("CogroupedKStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public CogroupedKStream(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

Aggregate(Initializer)

public KTable Aggregate(Initializer arg0)

Parameters

arg0 Initializer

Initializer

Returns

KTable

KTable

Aggregate(Initializer, Materialized)

public KTable Aggregate(Initializer arg0, Materialized arg1)

Parameters

arg0 Initializer

Initializer

arg1 Materialized

Materialized

Returns

KTable

KTable

Aggregate(Initializer, Named)

public KTable Aggregate(Initializer arg0, Named arg1)

Parameters

arg0 Initializer

Initializer

arg1 Named

Named

Returns

KTable

KTable

Aggregate(Initializer, Named, Materialized)

public KTable Aggregate(Initializer arg0, Named arg1, Materialized arg2)

Parameters

arg0 Initializer

Initializer

arg1 Named

Named

arg2 Materialized

Materialized

Returns

KTable

KTable

Cogroup(KGroupedStream, Aggregator)

public CogroupedKStream Cogroup(KGroupedStream arg0, Aggregator arg1)

Parameters

arg0 KGroupedStream

KGroupedStream

arg1 Aggregator

Aggregator

Returns

CogroupedKStream

CogroupedKStream

WindowedBy(SessionWindows)

public SessionWindowedCogroupedKStream WindowedBy(SessionWindows arg0)

Parameters

arg0 SessionWindows

SessionWindows

Returns

SessionWindowedCogroupedKStream

SessionWindowedCogroupedKStream

WindowedBy(SlidingWindows)

public TimeWindowedCogroupedKStream WindowedBy(SlidingWindows arg0)

Parameters

arg0 SlidingWindows

SlidingWindows

Returns

TimeWindowedCogroupedKStream

TimeWindowedCogroupedKStream

WindowedBy(Windows)

public TimeWindowedCogroupedKStream WindowedBy(Windows arg0)

Parameters

arg0 Windows

Windows

Returns

TimeWindowedCogroupedKStream

TimeWindowedCogroupedKStream