Class KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of KeyValueMapper<K, V, VR>

public class KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR> : KeyValueMapper<TJVMK, TJVMV, TJVMVR>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IKeyValueMapper<TJVMK, TJVMV, TJVMVR>, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

K

key value type

V

first value type

VR

joined value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

TJVMVR

The JVM type of VR

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<JVMBridgeListener>

JVMBridgeListener

KeyValueMapper<TJVMK, TJVMV, TJVMVR>

KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IKeyValueMapper<TJVMK, TJVMV, TJVMVR>

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IGenericSerDesFactoryApplier

Derived

EnumerableKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>

KeyValueKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>

KeyValueMapperForString<K, V, TJVMK, TJVMV>

KeyValueMapper<K, V, VR>

Inherited Members

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.ListenerShallManageEvent(int)

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.BridgeClassName

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.InitializeHandlers(Type)

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.ListenerShallManageEventHandlers(int)

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.OnApply

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.OnApplyDispose

KeyValueMapper<TJVMK, TJVMV, TJVMVR>.Apply(TJVMK, TJVMV)

Constructors

KeyValueMapper()

public KeyValueMapper()

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

OnApply

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

public Func<K, V, VR> OnApply { get; set; }

Property Value

Func<K, V, VR>

Remarks

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

Methods

Apply(K, V)

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

public virtual VR Apply(K arg0, V arg1)

Parameters

arg0 K

K

arg1 V

V

Returns

VR

VR

Apply(TJVMK, TJVMV)

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

public override TJVMVR Apply(TJVMK arg0, TJVMV arg1)

Parameters

arg0 TJVMK

K

arg1 TJVMV

V

Returns

TJVMVR

VR

DisposeResult(TJVMVR)

Disposes the results of the Apply(K, V) or OnApply operations

protected virtual void DisposeResult(TJVMVR result)

Parameters

result TJVMVR

The result to be disposed