public class VertexParallelismWithSlotSharing extends Object implements VertexParallelism
VertexParallelism
implementation for the SlotSharingSlotAllocator
.Modifier and Type | Method and Description |
---|---|
Map<JobVertexID,Integer> |
getMaxParallelismForVertices() |
int |
getParallelism(JobVertexID jobVertexId) |
public Map<JobVertexID,Integer> getMaxParallelismForVertices()
getMaxParallelismForVertices
in interface VertexParallelism
public int getParallelism(JobVertexID jobVertexId)
getParallelism
in interface VertexParallelism
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.