Interface SessionReducer

Interface that must be implemented for session reduce operations.

Provides three required methods for:

Processing messages in a session
Serializing state for checkpointing
Merging state from other sessions

interface SessionReducer {
    accumulatorFn: AccumulatorFnCallback;
    mergeAccumulatorFn: MergeAccumulatorFnCallback;
    sessionReduceFn: SessionReduceFnCallback;
}

Index

Properties

accumulatorFn mergeAccumulatorFn sessionReduceFn

Properties

accumulatorFn

accumulatorFn: AccumulatorFnCallback

Serialize current state to a Buffer for checkpointing

mergeAccumulatorFn

mergeAccumulatorFn: MergeAccumulatorFnCallback

Merge incoming state from another session

sessionReduceFn

sessionReduceFn: SessionReduceFnCallback

Main processing function that yields output messages