Package software.amazon.lambda.durable.operation

Class MapOperation<I,O>

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation

software.amazon.lambda.durable.operation.SerializableDurableOperation<T>

software.amazon.lambda.durable.operation.ConcurrencyOperation<MapResult<O>>

software.amazon.lambda.durable.operation.MapOperation<I,O>

Type Parameters:

I - the input item type

O - the output result type per item

All Implemented Interfaces:

DurableFuture<MapResult<O>>

public class MapOperation<I,O>
extends ConcurrencyOperation<MapResult<O>>

Executes a map operation: applies a function to each item in a collection concurrently, with each item running in its own child context.

Extends ConcurrencyOperation following the same pattern as ParallelOperation. All branches are created upfront in start()/replay(), and results are aggregated into a MapResult in get().

Nested Class Summary

Nested classes/interfaces inherited from class software.amazon.lambda.durable.operation.ConcurrencyOperation

ConcurrencyOperation.ExpectedCompletionStatus

Nested classes/interfaces inherited from class software.amazon.lambda.durable.operation.SerializableDurableOperation

SerializableDurableOperation.SerializedResult<T>

Field Summary

Fields inherited from class software.amazon.lambda.durable.operation.ConcurrencyOperation

isJoined

Fields inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

completionFuture, executionManager, isVirtual, parentOperation, replayCompletedOperation

Constructor Summary

Constructors

Constructor	Description
MapOperation(OperationIdentifier operationIdentifier, List<I> items, DurableContext.MapFunction<I,O> function, TypeToken<O> itemResultType, MapConfig config, List<String> iterationNames, DurableContextImpl durableContext)
MapOperation(OperationIdentifier operationIdentifier, List<I> items, DurableContext.MapFunction<I,O> function, TypeToken<O> itemResultType, MapConfig config, DurableContextImpl durableContext)

Method Summary

Modifier and Type	Method	Description
MapResult<O>	get()	Blocks until the operation completes and returns the result.
protected void	handleCompletion(CompletionConfig.CompletionDecision completionDecision)	Called when the concurrency operation completes.
protected void	replay(software.amazon.awssdk.services.lambda.model.Operation existing)	Replays the operation from an existing checkpoint.
static List<String>	resolveIterationNames(String mapName, List<?> items, MapConfig config)	Resolves the operation name for every iteration of a map, applying the config's item namer when present and the default "<mapName>-iteration-N" naming otherwise.
protected void	start()	Starts the operation on first execution (no existing checkpoint).

Methods inherited from class software.amazon.lambda.durable.operation.ConcurrencyOperation

createItem, enqueueItem, executeItems, executeItems, getBranches, join

Methods inherited from class software.amazon.lambda.durable.operation.SerializableDurableOperation

deserializeException, deserializeResult, serDesContext, serializeAndDeserializeResult, serializeException

Methods inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

deregisterActiveThread, execute, extractErrorFromOperation, fireOnOperationEnd, getChildOperations, getCompletionFuture, getContext, getCurrentThreadContext, getErrorObject, getName, getOperation, getOperationId, getRunningUserHandler, getSubType, getType, interruptRunningUserHandler, isOperationCompleted, isRunningUserHandlerOwner, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, processCheckpointUpdate, registerActiveThread, runUserFunction, runUserHandler, sendOperationUpdate, sendOperationUpdateAsync, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForFirstOperationCompletion, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

MapOperation

public MapOperation(OperationIdentifier operationIdentifier,
 List<I> items,
 DurableContext.MapFunction<I,O> function,
 TypeToken<O> itemResultType,
 MapConfig config,
 DurableContextImpl durableContext)

MapOperation

public MapOperation(OperationIdentifier operationIdentifier,
 List<I> items,
 DurableContext.MapFunction<I,O> function,
 TypeToken<O> itemResultType,
 MapConfig config,
 List<String> iterationNames,
 DurableContextImpl durableContext)

Method Details

resolveIterationNames

public static List<String> resolveIterationNames(String mapName,
 List<?> items,
 MapConfig config)

Resolves the operation name for every iteration of a map, applying the config's item namer when present and the default "<mapName>-iteration-N" naming otherwise. A namer that returns null yields an unnamed iteration; any non-null name is validated here.

SDK-internal. This is the single source of iteration naming for both construction paths: the caller resolves names before an operation ID is allocated, and the legacy constructor resolves them on behalf of callers that do not.

Parameters:

mapName - the map operation's name, or null

items - the map's items, in iteration order

config - the map configuration supplying the optional item namer

Returns:

one name per item, in iteration order

start

protected void start()

Description copied from class: BaseDurableOperation

Starts the operation on first execution (no existing checkpoint).

Specified by:

start in class BaseDurableOperation

replay

protected void replay(software.amazon.awssdk.services.lambda.model.Operation existing)

Description copied from class: BaseDurableOperation

Replays the operation from an existing checkpoint.

Specified by:

replay in class BaseDurableOperation

Parameters:

existing - the checkpointed operation state

handleCompletion

protected void handleCompletion(CompletionConfig.CompletionDecision completionDecision)

Description copied from class: ConcurrencyOperation

Called when the concurrency operation completes. Subclasses define checkpointing behavior.

Specified by:

handleCompletion in class ConcurrencyOperation<MapResult<O>>

get

public MapResult<O> get()

Description copied from interface: DurableFuture

Blocks until the operation completes and returns the result.

This delegates to operation.get() which handles: - Thread deregistration (allows suspension) - Thread reactivation (resumes execution) - Result retrieval

Specified by:

get in interface DurableFuture<I>

Specified by:

get in class SerializableDurableOperation<MapResult<O>>

Returns:

the operation result