Package org.apache.hadoop.yarn.server.resourcemanager.reservation

Class ReservationSystemUtil

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.reservation.ReservationSystemUtil

public final class ReservationSystemUtil
extends Object

Simple helper class for static methods used to transform across common formats in tests

Method Summary

Modifier and Type	Method	Description
static org.apache.hadoop.yarn.proto.YarnProtos.ReservationAllocationStateProto	buildStateProto(ReservationAllocation allocation)
static List<org.apache.hadoop.yarn.api.records.ReservationAllocationState>	convertAllocationsToReservationInfo(Set<ReservationAllocation> res, boolean includeResourceAllocations)
static org.apache.hadoop.yarn.api.records.impl.pb.ReservationDefinitionPBImpl	convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnProtos.ReservationDefinitionProto r)
static org.apache.hadoop.yarn.api.records.impl.pb.ReservationIdPBImpl	convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnProtos.ReservationIdProto r)
static org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto	convertToProtoFormat(org.apache.hadoop.yarn.api.records.Resource e)
static Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource>	toAllocations(List<org.apache.hadoop.yarn.proto.YarnProtos.ResourceAllocationRequestProto> allocationRequestsList)
static InMemoryReservationAllocation	toInMemoryAllocation(String planName, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.proto.YarnProtos.ReservationAllocationStateProto allocationState, org.apache.hadoop.yarn.api.records.Resource minAlloc, org.apache.hadoop.yarn.util.resource.ResourceCalculator planResourceCalculator)
static org.apache.hadoop.yarn.api.records.ReservationId	toReservationId(org.apache.hadoop.yarn.proto.YarnProtos.ReservationIdProto reservationId)
static org.apache.hadoop.yarn.api.records.Resource	toResource(org.apache.hadoop.yarn.api.records.ReservationRequest request)
static Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource>	toResources(Map<ReservationInterval,org.apache.hadoop.yarn.api.records.ReservationRequest> allocations)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

toResource

public static org.apache.hadoop.yarn.api.records.Resource toResource(org.apache.hadoop.yarn.api.records.ReservationRequest request)

toResources

public static Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> toResources(Map<ReservationInterval,org.apache.hadoop.yarn.api.records.ReservationRequest> allocations)

buildStateProto

public static org.apache.hadoop.yarn.proto.YarnProtos.ReservationAllocationStateProto buildStateProto(ReservationAllocation allocation)

convertToProtoFormat

public static org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto convertToProtoFormat(org.apache.hadoop.yarn.api.records.Resource e)

toAllocations

public static Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> toAllocations(List<org.apache.hadoop.yarn.proto.YarnProtos.ResourceAllocationRequestProto> allocationRequestsList)

convertFromProtoFormat

public static org.apache.hadoop.yarn.api.records.impl.pb.ReservationDefinitionPBImpl convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnProtos.ReservationDefinitionProto r)

convertFromProtoFormat

public static org.apache.hadoop.yarn.api.records.impl.pb.ReservationIdPBImpl convertFromProtoFormat(org.apache.hadoop.yarn.proto.YarnProtos.ReservationIdProto r)

toReservationId

public static org.apache.hadoop.yarn.api.records.ReservationId toReservationId(org.apache.hadoop.yarn.proto.YarnProtos.ReservationIdProto reservationId)

toInMemoryAllocation

public static InMemoryReservationAllocation toInMemoryAllocation(String planName,
 org.apache.hadoop.yarn.api.records.ReservationId reservationId,
 org.apache.hadoop.yarn.proto.YarnProtos.ReservationAllocationStateProto allocationState,
 org.apache.hadoop.yarn.api.records.Resource minAlloc,
 org.apache.hadoop.yarn.util.resource.ResourceCalculator planResourceCalculator)

convertAllocationsToReservationInfo

public static List<org.apache.hadoop.yarn.api.records.ReservationAllocationState> convertAllocationsToReservationInfo(Set<ReservationAllocation> res,
 boolean includeResourceAllocations)