Class Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>

Namespace

MASES.KNet.Streams.Processor.Api

Assembly

MASES.KNet.dll

KNet extension of Processor<KIn, VIn, KOut, VOut>

public abstract class Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut> : Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IProcessor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

KIn

The input key type

VIn

The input key type

KOut

The output key type

VOut

The output value type

TJVMKIn

The JVM type of KIn

TJVMVIn

The JVM type of VIn

TJVMKOut

The JVM type of KOut

TJVMVOut

The JVM type of VOut

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<JVMBridgeListener>

JVMBridgeListener

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>

Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IProcessor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>

IJVMBridgeBase

IJVMBridgeDefinition

IGenericSerDesFactoryApplier

Derived

Processor<KIn, VIn, KOut, VOut>

Inherited Members

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.BridgeClassName

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.InitializeHandlers()

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.OnProcess

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.Process(Record<TJVMKIn, TJVMVIn>)

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.CloseDefault()

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.OnClose

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.Close()

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.InitDefault(ProcessorContext<TJVMKOut, TJVMVOut>)

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.OnInit

Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>.Init(ProcessorContext<TJVMKOut, TJVMVOut>)

JVMBridgeListener.AddEventHandler(string, EventHandler)

JVMBridgeListener.AddEventHandler<TDataClass>(string, EventHandler<CLRListenerEventArgs<TDataClass>>)

JVMBridgeListener.Dispose()

JVMBridgeListener.BridgeClassName

JVMBridgeListener.AutoInit

JVMBridgeListener.IsBridgeStatic

JVMBridgeListener.IsBridgeCloseable

JVMBridgeListener.IsBridgeListener

JVMBridgeBase<JVMBridgeListener>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<JVMBridgeListener>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<JVMBridgeListener>.SGetField(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetField(string)

JVMBridgeBase<JVMBridgeListener>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetField<TReturn>(string)

JVMBridgeBase<JVMBridgeListener>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<JVMBridgeListener>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<JVMBridgeListener>.SSetField(IJavaType, string, object)

JVMBridgeBase<JVMBridgeListener>.SSetField(string, object)

JVMBridgeBase<JVMBridgeListener>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<JVMBridgeListener>.SSetField<TValue>(string, TValue)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(string)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)

JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()

JVMBridgeBase<JVMBridgeListener>.New(params object[])

JVMBridgeBase<JVMBridgeListener>.NewWithSignature(string, params object[])

JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])

JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz

JVMBridgeBase<JVMBridgeListener>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeInterface

JVMBridgeBase.IsBridgeAbstract

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Properties

Context

ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward> received from the init

public abstract ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut> Context { get; }

Property Value

ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut>

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

OnInit

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/Processor.html#init-org.apache.kafka.streams.processor.api.ProcessorContext-

public Action<ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut>> OnInit { get; set; }

Property Value

Action<ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut>>

Remarks

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

OnProcess

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/processor/api/Processor.html#process-org.apache.kafka.streams.processor.api.Record-

public Action<Record<KIn, VIn, TJVMKIn, TJVMVIn>> OnProcess { get; set; }

Property Value

Action<Record<KIn, VIn, TJVMKIn, TJVMVIn>>

Remarks

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

Methods

Init(ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut>)

KNet implementation of Init(ProcessorContext<KOut, VOut>)

public virtual void Init(ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut> arg0)

Parameters

arg0 ProcessorContext<KOut, VOut, TJVMKOut, TJVMVOut>

ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

Process(Record<KIn, VIn, TJVMKIn, TJVMVIn>)

KNet implementation of Process(Record<KIn, VIn>)

public virtual void Process(Record<KIn, VIn, TJVMKIn, TJVMVIn> arg0)

Parameters

arg0 Record<KIn, VIn, TJVMKIn, TJVMVIn>

Record<K, V, TJVMK, TJVMV>