Namespace MASES.KNet.Streams.Processor.Api

Classes

ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>

KNet implementation of ProcessorContext<KForward, VForward>

Processor<KIn, VIn, KOut, VOut>

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

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

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

Record<K, V, TJVMK, TJVMV>

KNet extension of Record<K, V>