Class Initializer<VA, TJVMVA>

Namespace

MASES.KNet.Streams.Kstream

Assembly

MASES.KNet.dll

KNet implementation of Initializer<VAgg>

public class Initializer<VA, TJVMVA> : Initializer<TJVMVA>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IInitializer<TJVMVA>, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

VA

The key type

TJVMVA

The JVM type of VA

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<JVMBridgeListener>

JVMBridgeListener

Initializer<TJVMVA>

Initializer<VA, TJVMVA>

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IInitializer<TJVMVA>

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

IGenericSerDesFactoryApplier

Derived

Initializer<VA>

Inherited Members

Initializer<TJVMVA>.ListenerShallManageEvent(int)

Initializer<TJVMVA>.BridgeClassName

Initializer<TJVMVA>.InitializeHandlers(Type)

Initializer<TJVMVA>.ListenerShallManageEventHandlers(int)

Initializer<TJVMVA>.OnApply

Initializer<TJVMVA>.OnApplyDispose

Constructors

Initializer()

public Initializer()

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

OnApply2

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Initializer.html#apply()

public Func<VA> OnApply2 { get; set; }

Property Value

Func<VA>

Remarks

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

Methods

Apply()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Initializer.html#apply()

public override sealed TJVMVA Apply()

Returns

TJVMVA

VAgg

Apply2()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Initializer.html#apply()

public virtual VA Apply2()

Returns

VA

VAgg

DisposeResult(TJVMVA)

Disposes the results of the Apply() or OnApply2 operations

protected virtual void DisposeResult(TJVMVA result)

Parameters

result TJVMVA

The result to be disposed