Table of Contents

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, IEquatable<IJVMBridgeBase>, 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
Processor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>
Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>
Implements
IProcessor<TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>
Derived
Inherited Members

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/4.1.0/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/4.1.0/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>

Edit this page