Package software.amazon.lambda.durable.operation

Class ParallelOperation

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation

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

software.amazon.lambda.durable.operation.ConcurrencyOperation<ParallelResult>

software.amazon.lambda.durable.operation.ParallelOperation

All Implemented Interfaces:

AutoCloseable, DurableFuture<ParallelResult>, SafeCloseable, ParallelDurableFuture

public class ParallelOperation
extends ConcurrencyOperation<ParallelResult>
implements ParallelDurableFuture

Manages parallel execution of multiple branches as child context operations.

Extends ConcurrencyOperation to provide parallel-specific behavior:

• Creates branches as ChildContextOperation with OperationSubType.PARALLEL_BRANCH
• Checkpoints SUCCESS on the parallel context when completion criteria are met
• Returns a ParallelResult summarising branch outcomes

Context hierarchy:

 DurableContext (root)
   └── ParallelOperation context (ChildContextOperation with PARALLEL subtype)
         ├── Branch 1 context (ChildContextOperation with PARALLEL_BRANCH)
         ├── Branch 2 context (ChildContextOperation with PARALLEL_BRANCH)
         └── Branch N context (ChildContextOperation with PARALLEL_BRANCH)
 

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
ParallelOperation(OperationIdentifier operationIdentifier, SerDes resultSerDes, DurableContextImpl durableContext, ParallelConfig config)

Method Summary

Modifier and Type	Method	Description
<T> DurableFuture<T>	branch(String name, TypeToken<T> resultType, Function<DurableContext,T> func, ParallelBranchConfig config)	Registers and immediately starts a branch (respects maxConcurrency).
void	close()	Calls get() if not already called.
ParallelResult	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.
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

Methods inherited from interface software.amazon.lambda.durable.ParallelDurableFuture

branch, branch, branch

Constructor Details

ParallelOperation

public ParallelOperation(OperationIdentifier operationIdentifier,
 SerDes resultSerDes,
 DurableContextImpl durableContext,
 ParallelConfig config)

Method Details

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<ParallelResult>

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

get

public ParallelResult 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<ParallelResult>

Specified by:

get in class SerializableDurableOperation<ParallelResult>

Returns:

the operation result

close

public void close()

Calls get() if not already called. Guarantees that the context is closed.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

branch

public <T> DurableFuture<T> branch(String name,
 TypeToken<T> resultType,
 Function<DurableContext,T> func,
 ParallelBranchConfig config)

Description copied from interface: ParallelDurableFuture

Registers and immediately starts a branch (respects maxConcurrency).

Specified by:

branch in interface ParallelDurableFuture

Type Parameters:

T - the result type

Parameters:

name - the branch name

resultType - the result type token for generic types

func - the function to execute in the branch's child context

Returns:

a DurableFuture that will contain the branch result