Package com.koralix.stepfn

Class Step<T,R>

java.lang.Object

com.koralix.stepfn.Step<T,R>

Type Parameters:

T - the type of the input to the step

R - the type of the result of the step

All Implemented Interfaces:

Function<T,R>

public abstract class Step<T,R>
extends Object
implements Function<T,R>

A Step is a Function that is part of a StepFunction.

Since:

1.0.0

See Also:

• StepFunction

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Step<?,?>,T>	aggregation	The aggregation of the inputs from the previous steps.
protected T	stepFunctionInput	The input from the step function.

Constructor Summary

Constructors

Constructor	Description
Step()

Method Summary

Modifier and Type	Method	Description
void	aggregate(Step<?,?> from, T input)	Aggregates the given input from the given step.
abstract boolean	isComplete()	Checks if the step has all the required inputs to be executed.

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.Function

andThen, apply, compose

Field Details

aggregation

protected final Map<Step<?,?>,T> aggregation

The aggregation of the inputs from the previous steps.

Since:

1.0.0

stepFunctionInput

protected T stepFunctionInput

The input from the step function.

This is only used for the first step.

Since:

1.0.0

Constructor Details

Step

public Step()

Method Details

aggregate

public void aggregate(Step<?,?> from,
 T input)

Aggregates the given input from the given step.

Parameters:

from - the step that produced the input

input - the input

Since:

1.0.0

isComplete

public abstract boolean isComplete()

Checks if the step has all the required inputs to be executed.

Returns:

true if the step is complete, false otherwise

Since:

1.0.0