public class DefaultVertexParallelismStore extends Object implements MutableVertexParallelismStore
Constructor and Description |
---|
DefaultVertexParallelismStore() |
Modifier and Type | Method and Description |
---|---|
static Optional<VertexParallelismStore> |
applyJobResourceRequirements(VertexParallelismStore oldVertexParallelismStore,
JobResourceRequirements jobResourceRequirements)
Create a new
VertexParallelismStore that reflects given JobResourceRequirements . |
VertexParallelismInformation |
getParallelismInfo(JobVertexID vertexId)
Returns a given vertex's parallelism information.
|
void |
setParallelismInfo(JobVertexID vertexId,
VertexParallelismInformation info)
Sets the parallelism properties for the given vertex.
|
public static Optional<VertexParallelismStore> applyJobResourceRequirements(VertexParallelismStore oldVertexParallelismStore, JobResourceRequirements jobResourceRequirements)
VertexParallelismStore
that reflects given JobResourceRequirements
.oldVertexParallelismStore
- old vertex parallelism store that serves as a base for the
new onejobResourceRequirements
- to apply over the old vertex parallelism storepublic void setParallelismInfo(JobVertexID vertexId, VertexParallelismInformation info)
MutableVertexParallelismStore
setParallelismInfo
in interface MutableVertexParallelismStore
vertexId
- vertex to set parallelism forinfo
- parallelism information for the given vertexpublic VertexParallelismInformation getParallelismInfo(JobVertexID vertexId)
VertexParallelismStore
getParallelismInfo
in interface VertexParallelismStore
vertexId
- vertex for which the parallelism information should be returnedCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.