Table of Contents

Class ValueJoiner<V1, V2, VR>

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

Listener for Kafka ValueJoiner. Extends 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
ValueJoiner<V1, V2, VR>
Implements
IValueJoiner<V1, V2, VR>
Derived
Inherited Members

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()

ValueJoiner(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public ValueJoiner(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

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()