public interface VertexParallelism
SlotAllocator.determineParallelism(JobInformation, Collection)
, describing
the parallelism each vertex could be scheduled with.
SlotAllocator
implementations may encode additional information to be used in SlotAllocator.tryReserveResources(VertexParallelism)
.
Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,Integer> |
getMaxParallelismForVertices() |
int |
getParallelism(JobVertexID jobVertexId) |
Map<JobVertexID,Integer> getMaxParallelismForVertices()
int getParallelism(JobVertexID jobVertexId)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.