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
-
Processor<KIn, VIn, KOut, VOut>
- Implements
- Inherited Members
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)