Table of Contents

Class ValueMapper<V, VR, TJVMV, TJVMVR>

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

KNet extension of ValueMapper<V, VR>

public class ValueMapper<V, VR, TJVMV, TJVMVR> : ValueMapper<TJVMV, TJVMVR>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IValueMapper<TJVMV, TJVMVR>, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

V

first value type

VR

joined value type

TJVMV

The JVM type of V

TJVMVR

The JVM type of VR

Inheritance
ValueMapper<TJVMV, TJVMVR>
ValueMapper<V, VR, TJVMV, TJVMVR>
Implements
IValueMapper<TJVMV, TJVMVR>
Derived
Inherited Members

Constructors

ValueMapper() 

public ValueMapper()

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/ValueMapperWithKey.html#apply(java.lang.Object,java.lang.Object)

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

Property Value

Func<V, VR>

Remarks

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

Methods

Apply(V)

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

public virtual VR Apply(V arg0)

Parameters

arg0 V

V

Returns

VR

VR

Apply(TJVMV)

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

public override TJVMVR Apply(TJVMV arg0)

Parameters

arg0 TJVMV

V

Returns

TJVMVR

VR

DisposeResult(TJVMVR)

Disposes the results of the Apply(TJVMV) or OnApply operations

protected virtual void DisposeResult(TJVMVR result)

Parameters

result TJVMVR

The result to be disposed

Edit this page