Package software.amazon.lambda.durable.model

Record Class MapResult<T>

java.lang.Object
java.lang.Record
software.amazon.lambda.durable.model.MapResult<T>
Type Parameters:
T - the result type of each item
Record Components:
items - ordered result items from the map operation
completionReason - why the operation completed
public record MapResult<T>(List<MapResult.MapResultItem<T>> items, ConcurrencyCompletionStatus completionReason) extends Record
Result container for map operations.

Holds ordered results from a map operation. Each index corresponds to the input item at the same position. Each item is represented as a MapResult.MapResultItem containing its status, result, and error. Includes the ConcurrencyCompletionStatus indicating why the operation completed.

Errors are stored as MapResult.MapError rather than raw Throwable, so they survive serialization across checkpoint-and-replay cycles without requiring AWS SDK-specific Jackson modules.

  • Constructor Details

  • Method Details

    • empty

      public static <T> MapResult<T> empty()
      Returns an empty MapResult with no items.

    • getItem

      public MapResult.MapResultItem<T> getItem(int index)
      Returns the result item at the given index.

    • getResult

      public T getResult(int index)
      Returns the result at the given index, or null if that item failed or was not started.

    • getError

      public MapResult.MapError getError(int index)
      Returns the error at the given index, or null if that item succeeded or was not started.

    • allSucceeded

      public boolean allSucceeded()
      Returns true if all items succeeded (no failures or not-started items).

    • size

      public int size()
      Returns the number of items in this result.

    • results

      public List<T> results()
      Returns all results as an unmodifiable list (nulls for failed/not-started items).

    • succeeded

      public List<T> succeeded()
      Returns results from items that succeeded (includes null results from successful items).

    • failed

      public List<MapResult.MapError> failed()
      Returns errors from items that failed.

    • toString

      public final String toString()
      Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.
      Specified by:
      toString in class Record
      Returns:
      a string representation of this object

    • hashCode

      public final int hashCode()
      Returns a hash code value for this object. The value is derived from the hash code of each of the record components.
      Specified by:
      hashCode in class Record
      Returns:
      a hash code value for this object

    • equals

      public final boolean equals(Object o)
      Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. All components in this record class are compared with Objects::equals(Object,Object).
      Specified by:
      equals in class Record
      Parameters:
      o - the object with which to compare
      Returns:
      true if this object is the same as the o argument; false otherwise.

    • items

      public List<MapResult.MapResultItem<T>> items()
      Returns the value of the items record component.
      Returns:
      the value of the items record component

    • completionReason

      public ConcurrencyCompletionStatus completionReason()
      Returns the value of the completionReason record component.
      Returns:
      the value of the completionReason record component