Class AggregationWithHeaders<AGG, TJVMAGG>

Namespace

MASES.KNet.Streams.State

Assembly

MASES.KNet.dll

KNet Implementation of ValueAndTimestamp<V>

public class AggregationWithHeaders<AGG, TJVMAGG> : IKNetInnerReference<AggregationWithHeaders<TJVMAGG>>, IGenericSerDesFactoryApplier, IDisposable

Type Parameters

AGG

The value type

TJVMAGG

The JVM type of AGG

Inheritance

object

AggregationWithHeaders<AGG, TJVMAGG>

Implements

IKNetInnerReference<AggregationWithHeaders<TJVMAGG>>

IGenericSerDesFactoryApplier

IDisposable

Properties

Aggregation

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.3.1/org/apache/kafka/streams/state/AggregationWithHeaders.html#aggregation()

public AGG Aggregation { get; }

Property Value

AGG

AGG

Headers

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.3.1/org/apache/kafka/streams/state/ValueTimestampHeaders.html#headers()

public Headers Headers { get; }

Property Value

Headers

Headers

InnerReference

The underlying inner reference used from KNet object instance

public AggregationWithHeaders<TJVMAGG> InnerReference { get; }

Property Value

AggregationWithHeaders<TJVMAGG>

Methods

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

The disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)