public static interface ExecutionDeployer.Factory
ExecutionDeployer
.Modifier and Type | Method and Description |
---|---|
ExecutionDeployer |
createInstance(org.slf4j.Logger log,
ExecutionSlotAllocator executionSlotAllocator,
ExecutionOperations executionOperations,
ExecutionVertexVersioner executionVertexVersioner,
Time partitionRegistrationTimeout,
java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc,
ComponentMainThreadExecutor mainThreadExecutor)
Instantiate an
ExecutionDeployer with the given params. |
ExecutionDeployer createInstance(org.slf4j.Logger log, ExecutionSlotAllocator executionSlotAllocator, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, Time partitionRegistrationTimeout, java.util.function.BiConsumer<ExecutionVertexID,AllocationID> allocationReservationFunc, ComponentMainThreadExecutor mainThreadExecutor)
ExecutionDeployer
with the given params. Note that the version of
an execution vertex will be recorded before scheduling executions for it. The version may
change if a global failure happens, or if the job is canceled, or if the execution vertex
is restarted when all its current execution are FAILED/CANCELED. Once the version is
changed, the previously triggered execution deployment will be skipped.log
- the loggerexecutionSlotAllocator
- the allocator to allocate slotsexecutionOperations
- the operations of executionsexecutionVertexVersioner
- the versioner which records the versions of execution
vertices.partitionRegistrationTimeout
- timeout of partition registrationallocationReservationFunc
- function to reserve allocations for local recoverymainThreadExecutor
- the main thread executorExecutionDeployer
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.