Class ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet extension of ValueJoinerWithKey<K1, V1, V2, VR>

public class ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR> : ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

K1

key value type

V1

first value type

V2

second value type

VR

joined value type

TJVMK1

The JVM type of K1

TJVMV1

The JVM type of V1

TJVMV2

The JVM type of V2

TJVMVR

The JVM type of VR

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<JVMBridgeListener>

JVMBridgeListener

ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>

ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>

IJVMBridgeBase

IJVMBridgeDefinition

IGenericSerDesFactoryApplier

Derived

ValueJoinerWithKey<K1, V1, V2, VR>

Inherited Members

ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>.BridgeClassName

ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>.InitializeHandlers()

ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>.OnApply

ValueJoinerWithKey<TJVMK1, TJVMV1, TJVMV2, TJVMVR>.Apply(TJVMK1, TJVMV1, TJVMV2)

JVMBridgeListener.AddEventHandler(string, EventHandler)

JVMBridgeListener.AddEventHandler<TDataClass>(string, EventHandler<CLRListenerEventArgs<TDataClass>>)

JVMBridgeListener.Dispose()

JVMBridgeListener.BridgeClassName

JVMBridgeListener.AutoInit

JVMBridgeListener.IsBridgeStatic

JVMBridgeListener.IsBridgeCloseable

JVMBridgeListener.IsBridgeListener

JVMBridgeBase<JVMBridgeListener>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SGetField(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetField(string)

JVMBridgeBase<JVMBridgeListener>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetField<TReturn>(string)

JVMBridgeBase<JVMBridgeListener>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<JVMBridgeListener>.SSetField(IJavaType, string, object)

JVMBridgeBase<JVMBridgeListener>.SSetField(string, object)

JVMBridgeBase<JVMBridgeListener>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<JVMBridgeListener>.SSetField<TValue>(string, TValue)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(string)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()

JVMBridgeBase<JVMBridgeListener>.New(params object[])

JVMBridgeBase<JVMBridgeListener>.NewWithSignature(string, params object[])

JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])

JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz

JVMBridgeBase<JVMBridgeListener>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeInterface

JVMBridgeBase.IsBridgeAbstract

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

Key

The K1 content

public virtual K1 Key { get; }

Property Value

K1

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<ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>, VR> OnApply { get; set; }

Property Value

Func<ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, 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(TJVMK1, TJVMV1, TJVMV2)

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

public override TJVMVR Apply(TJVMK1 arg0, TJVMV1 arg1, TJVMV2 arg2)

Parameters

arg0 TJVMK1

K1

arg1 TJVMV1

V1

arg2 TJVMV2

V2

Returns

TJVMVR

VR