Table of Contents

Class ValueJoinerWithKey<K1, V1, V2, VR>

Namespace
Org.Apache.Kafka.Streams.Kstream
Assembly
MASES.KNet.dll

Listener for Kafka ValueJoinerWithKey. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IValueJoinerWithKey<K1, V1, V2, VR>

public class ValueJoinerWithKey<K1, V1, V2, VR> : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IValueJoinerWithKey<K1, V1, V2, VR>, IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

K1
V1
V2
VR
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
ValueJoinerWithKey<K1, V1, V2, VR>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IValueJoinerWithKey<K1, V1, V2, VR>
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
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

Remarks

Dispose the object to avoid a resource leak, the object contains a reference to the corresponding JVM object

Constructors

ValueJoinerWithKey()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public ValueJoinerWithKey()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnApply

public Func<K1, V1, V2, VR> OnApply { get; set; }

Property Value

Func<K1, V1, V2, VR>

Remarks

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

Methods

Apply(K1, V1, V2)

public virtual VR Apply(K1 arg0, V1 arg1, V2 arg2)

Parameters

arg0 K1

K1

arg1 V1

V1

arg2 V2

V2

Returns

VR

VR

InitializeHandlers()

Handlers initializer for ValueJoinerWithKey

protected virtual void InitializeHandlers()