Table of Contents

Class ValueJoiner<V1, V2, VR>

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

Listener for Kafka ValueJoiner. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IValueJoiner<V1, V2, VR>

public class ValueJoiner<V1, V2, VR> : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IValueJoiner<V1, V2, VR>, IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

V1
V2
VR
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
ValueJoiner<V1, V2, VR>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IValueJoiner<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

ValueJoiner()

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

public ValueJoiner()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnApply

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

Property Value

Func<V1, V2, VR>

Remarks

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

Methods

Apply(V1, V2)

public virtual VR Apply(V1 arg0, V2 arg1)

Parameters

arg0 V1

V1

arg1 V2

V2

Returns

VR

VR

InitializeHandlers()

Handlers initializer for ValueJoiner

protected virtual void InitializeHandlers()