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
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
ValueTransformerWithKey<K, V, VR>
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
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

Constructors

ValueTransformerWithKey()

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

public ValueTransformerWithKey()

Properties

BridgeClassName

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