Class Processor<KIn, VIn, KOut, VOut>
KNet extension of Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>
public class Processor<KIn, VIn, KOut, VOut> : Processor<KIn, VIn, KOut, VOut, byte[], byte[], byte[], byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IProcessor<byte[], byte[], byte[], byte[]>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplierType Parameters
KInThe input key type
VInThe input key type
KOutThe output key type
VOutThe output value type
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerProcessor<KIn, VIn, KOut, VOut>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeListener.Dispose()JVMBridgeListener.BridgeClassNameJVMBridgeListener.AutoInitJVMBridgeListener.IsBridgeStaticJVMBridgeListener.IsBridgeCloseableJVMBridgeListener.IsBridgeListenerJVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])JVMBridgeBase<JVMBridgeListener>.DynBridgeClazzJVMBridgeBase<JVMBridgeListener>.BridgeClazzJVMBridgeBase.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.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeInterfaceJVMBridgeBase.IsBridgeAbstract
Properties
Context
ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward> received from the init
public override ProcessorContext<KOut, VOut, byte[], byte[]> Context { get; }Property Value
- ProcessorContext<KOut, VOut, byte[], byte[]>
OnInit
public Action<ProcessorContext<KOut, VOut, byte[], byte[]>> OnInit { get; set; }Property Value
- Action<ProcessorContext<KOut, VOut, byte[], byte[]>>
Remarks
If OnInit has a value it takes precedence over corresponding class method
OnProcess
public Action<Record<KIn, VIn, byte[], byte[]>> OnProcess { get; set; }Property Value
Remarks
If OnProcess has a value it takes precedence over corresponding class method
Methods
Init(ProcessorContext<byte[], byte[]>)
public override sealed void Init(ProcessorContext<byte[], byte[]> arg0)Parameters
arg0ProcessorContext<byte[], byte[]>
Remarks
The method invokes the default implementation in the JVM interface using InitDefault(ProcessorContext<KOut, VOut>); override the method to implement a different behavior
Process(Record<byte[], byte[]>)
public override sealed void Process(Record<byte[], byte[]> arg0)