Table of Contents

Class ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>

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

KNet extension of ValueJoiner<V1, V2, VR>

public class ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR> : ValueJoiner<TJVMV1, TJVMV2, TJVMVR>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IValueJoiner<TJVMV1, TJVMV2, TJVMVR>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

V1

first value type

V2

second value type

VR

joined value type

TJVMV1

The JVM type of V1

TJVMV2

The JVM type of V2

TJVMVR

The JVM type of VR

Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
ValueJoiner<TJVMV1, TJVMV2, TJVMVR>
ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IValueJoiner<TJVMV1, TJVMV2, TJVMVR>
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
JVMBridgeListener.BridgeClassName
JVMBridgeListener.AutoInit
JVMBridgeListener.IsBridgeStatic
JVMBridgeListener.IsBridgeCloseable
JVMBridgeListener.IsBridgeListener
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()
JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])
JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz
JVMBridgeBase<JVMBridgeListener>.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.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeInterface
JVMBridgeBase.IsBridgeAbstract

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/3.7.1/org/apache/kafka/streams/kstream/ValueJoinerWithKey.html#apply-java.lang.Object-java.lang.Object-java.lang.Object-

public Func<ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>, VR> OnApply { get; set; }

Property Value

Func<ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>, VR>

Remarks

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

Value1

The V1 content

public virtual V1 Value1 { get; }

Property Value

V1

Value2

The V2 content

public virtual V2 Value2 { get; }

Property Value

V2

Methods

Apply()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/ValueJoinerWithKey.html#apply-java.lang.Object-java.lang.Object-java.lang.Object-

public virtual VR Apply()

Returns

VR

VR

Apply(TJVMV1, TJVMV2)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/kstream/ValueJoiner.html#apply-java.lang.Object-java.lang.Object-

public override sealed TJVMVR Apply(TJVMV1 arg0, TJVMV2 arg1)

Parameters

arg0 TJVMV1

V1

arg1 TJVMV2

V2

Returns

TJVMVR

VR

Edit this page