Table of Contents

Class ValueTransformerWithKey<K, V, VR>

Namespace
Org.Apache.Kafka.Streams.Kstream
Assembly
MASES.KNet.dll
public class ValueTransformerWithKey<K, V, VR> : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IValueTransformerWithKey<K, V, VR>

Type Parameters

K
V
VR
Inheritance
ValueTransformerWithKey<K, V, VR>
Implements
Derived
Inherited Members

Constructors

ValueTransformerWithKey()

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

public ValueTransformerWithKey()

ValueTransformerWithKey(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 ValueTransformerWithKey(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

OnClose

public Action OnClose { get; set; }

Property Value

Action

Remarks

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

OnInit

public Action<ProcessorContext> OnInit { get; set; }

Property Value

Action<ProcessorContext>

Remarks

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

OnTransform

public Func<K, V, VR> OnTransform { get; set; }

Property Value

Func<K, V, VR>

Remarks

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

Methods

Close()

public virtual void Close()

Init(ProcessorContext)

public virtual void Init(ProcessorContext arg0)

Parameters

arg0 ProcessorContext

ProcessorContext

InitializeHandlers()

Handlers initializer for ValueTransformerWithKey

protected virtual void InitializeHandlers()

Transform(K, V)

public virtual VR Transform(K arg0, V arg1)

Parameters

arg0 K

K

arg1 V

V

Returns

VR

VR