Table of Contents

Class Reducer<V, TJVMV>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll

KNet extension of Reducer<V>

public class Reducer<V, TJVMV> : Reducer<TJVMV>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IReducer<TJVMV>, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IGenericSerDesFactoryApplier

Type Parameters

V

value type

TJVMV

The JVM type of V

Inheritance
Reducer<TJVMV>
Reducer<V, TJVMV>
Implements
IReducer<TJVMV>
Derived
Inherited Members

Constructors

Reducer() 

public Reducer()

Properties

Factory

Returns the current IGenericSerDesFactory

protected IGenericSerDesFactory Factory { get; }

Property Value

IGenericSerDesFactory

OnApply

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/ValueMapperWithKey.html#apply(java.lang.Object,java.lang.Object)

public Func<Reducer<V, TJVMV>, V> OnApply { get; set; }

Property Value

Func<Reducer<V, TJVMV>, V>

Remarks

If OnApply has a value it takes precedence over corresponding Apply() class method

Value1

The V content

public virtual V Value1 { get; }

Property Value

V

Value2

The V content

public virtual V Value2 { get; }

Property Value

V

Methods

Apply()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Reducer.html#apply(java.lang.Object,java.lang.Object)

public virtual V Apply()

Returns

V

V

Apply(TJVMV, TJVMV)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Reducer.html#apply(java.lang.Object,java.lang.Object)

public override TJVMV Apply(TJVMV arg0, TJVMV arg1)

Parameters

arg0 TJVMV

V

arg1 TJVMV

V

Returns

TJVMV

V

DisposeResult(TJVMV)

Disposes the results of the Apply(TJVMV, TJVMV) or OnApply operations

protected virtual void DisposeResult(TJVMV result)

Parameters

result TJVMV

The result to be disposed

Edit this page