Package io.axoniq.framework.workflow.runtime.execution.payload

Class CombineGlobalAndLocalPayloadReducer

java.lang.Object

io.axoniq.framework.workflow.runtime.execution.payload.CombineGlobalAndLocalPayloadReducer

All Implemented Interfaces:

PayloadReducer, BiFunction<Map<String,@Nullable Object>,Map<String,@Nullable Object>,Map<String,@Nullable Object>>

public class CombineGlobalAndLocalPayloadReducer
extends Object
implements PayloadReducer

Combines two payloads into one. Takes all values from the first payload (workflow context) and adds the values of the second (local), overwriting any duplicates. Usage of this reducer as a parameter reducer allows accessing all workflow context variables directly. Usage of this reducer as a result reducer writes all results back into the workflow context.

Since:

5.4.0

Author:

Simon Zambrovski

Field Summary

Fields

Modifier and Type	Field	Description
static final CombineGlobalAndLocalPayloadReducer	INSTANCE	Singleton instance of CombineGlobalAndLocalPayloadReducer.
static final String	NAME	Name of CombineGlobalAndLocalPayloadReducer reducer.

Constructor Summary

Constructors

Constructor	Description
CombineGlobalAndLocalPayloadReducer()

Method Summary

Modifier and Type	Method	Description
Map<String,@Nullable Object>	apply(Map<String,@Nullable Object> global, Map<String,@Nullable Object> local)
String	name()	Retrieves the name of the reducer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Field Details

NAME

public static final String NAME

Name of CombineGlobalAndLocalPayloadReducer reducer.

See Also:

• Constant Field Values

INSTANCE

public static final CombineGlobalAndLocalPayloadReducer INSTANCE

Singleton instance of CombineGlobalAndLocalPayloadReducer.

Constructor Details

CombineGlobalAndLocalPayloadReducer

public CombineGlobalAndLocalPayloadReducer()

Method Details

apply

public Map<String,@Nullable Object> apply(Map<String,@Nullable Object> global,
 Map<String,@Nullable Object> local)

Specified by:

apply in interface BiFunction<Map<String,@Nullable Object>,Map<String,@Nullable Object>,Map<String,@Nullable Object>>

name

public String name()

Description copied from interface: PayloadReducer

Retrieves the name of the reducer.

Specified by:

name in interface PayloadReducer

Returns:

reducer name.