public class SsgNetworkMemoryCalculationUtils extends Object
ExecutionJobVertex
and calculate network memory
requirement for slot sharing group (SSG).Modifier and Type | Method and Description |
---|---|
static void |
enrichNetworkMemory(SlotSharingGroup ssg,
java.util.function.Function<JobVertexID,ExecutionJobVertex> ejvs,
ShuffleMaster<?> shuffleMaster)
Calculates network memory requirement of
ExecutionJobVertex and update ResourceProfile of corresponding slot sharing group. |
public static void enrichNetworkMemory(SlotSharingGroup ssg, java.util.function.Function<JobVertexID,ExecutionJobVertex> ejvs, ShuffleMaster<?> shuffleMaster)
ExecutionJobVertex
and update ResourceProfile
of corresponding slot sharing group.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.