Table of Contents

Class ForeachAction<K, V, TJVMK, TJVMV>

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

KNet extension of ForeachAction<K, V>

public class ForeachAction<K, V, TJVMK, TJVMV> : ForeachAction<TJVMK, TJVMV>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IForeachAction<TJVMK, TJVMV>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

K

key value type

V

first value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance
ForeachAction<TJVMK, TJVMV>
ForeachAction<K, V, TJVMK, TJVMV>
Implements
IForeachAction<TJVMK, TJVMV>
Derived
Inherited Members

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

Key

The K content

public virtual K Key { get; }

Property Value

K

OnApply

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/ForeachAction.html#apply(java.lang.Object-java.lang.Object)

public Action<ForeachAction<K, V, TJVMK, TJVMV>> OnApply { get; set; }

Property Value

Action<ForeachAction<K, V, TJVMK, TJVMV>>

Remarks

If OnApply has a value it takes precedence over corresponding Apply() class method

Value

The V content

public virtual V Value { get; }

Property Value

V

Methods

Apply()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/ForeachAction.html#apply(java.lang.Object,java.lang.Object)

public virtual void Apply()

Apply(TJVMK, TJVMV)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/ForeachAction.html#apply(java.lang.Object,java.lang.Object)

public override sealed void Apply(TJVMK arg0, TJVMV arg1)

Parameters

arg0 TJVMK

K

arg1 TJVMV

V

Edit this page