Table of Contents

Class EnumerableValueMapper<V, VR, TJVMV, TJVMVR>

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

KNet extension of ValueMapper<V, VR, TJVMV, TJVMVR>

public class EnumerableValueMapper<V, VR, TJVMV, TJVMVR> : ValueMapper<V, VR, TJVMV, Iterable<TJVMVR>>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IValueMapper<TJVMV, Iterable<TJVMVR>>, IJVMBridgeBase, 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, Iterable<TJVMVR>>
ValueMapper<V, VR, TJVMV, Iterable<TJVMVR>>
EnumerableValueMapper<V, VR, TJVMV, TJVMVR>
Implements
IValueMapper<TJVMV, Iterable<TJVMVR>>
Derived
Inherited Members

Properties

OnApply

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

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

Property Value

Func<V, IEnumerable<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.0.0/org/apache/kafka/streams/kstream/ValueMapper.html#apply(java.lang.Object)

public virtual IEnumerable<VR> Apply(V arg0)

Parameters

arg0 V

V

Returns

IEnumerable<VR>

VR

Apply(TJVMV)

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

public override Iterable<TJVMVR> Apply(TJVMV arg0)

Parameters

arg0 TJVMV

V

Returns

Iterable<TJVMVR>

Java.Lang.Iterable

Edit this page