Package org.apache.hadoop.yarn.server.router.clientrm

Class RouterYarnClientUtils

java.lang.Object
org.apache.hadoop.yarn.server.router.clientrm.RouterYarnClientUtils
public final class RouterYarnClientUtils extends Object
Util class for Router Yarn client API calls.

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse
    merge(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse> responses)
     
    static org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse
    mergeApplications(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse> responses, boolean returnPartialResult)
    Merges a list of ApplicationReports grouping by ApplicationId.
    static org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse
    mergeAttributesToNodesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse> responses)
    Merges a list of GetAttributesToNodesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse
    mergeClusterNodeAttributesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse> responses)
    Merges a list of GetClusterNodeAttributesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse
    mergeClusterNodeLabelsResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse> responses)
    Merges a list of GetClusterNodeLabelsResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse
    mergeClusterNodesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse> responses)
    Merges a list of GetClusterNodesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse
    mergeClusterResourceProfileResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse> responses)
    Merges a list of GetResourceProfileResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse
    mergeClusterResourceProfilesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse> responses)
    Merges a list of GetAllResourceProfilesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse
    mergeLabelsToNodes(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse> responses)
    Merges a list of GetLabelsToNodesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse
    mergeNodesToAttributesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse> responses)
    Merges a list of GetNodesToAttributesResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse
    mergeNodesToLabelsResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse> responses)
    Merges a list of GetNodesToLabelsResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse
    mergeQueues(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse> responses)
    Merges a list of GetQueueInfoResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse
    mergeQueueUserAcls(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse> responses)
    Merges a list of GetQueueUserAclsInfoResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse
    mergeReservationsList(Collection<org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse> responses)
    Merges a list of ReservationListResponse.
    static org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse
    mergeResourceTypes(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse> responses)
    Merges a list of GetAllResourceTypeInfoResponse.

    Methods inherited from class java.lang.Object

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

  • Method Details

    • merge

      public static org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse merge(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse> responses)

    • mergeApplications

      public static org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse mergeApplications(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse> responses, boolean returnPartialResult)
      Merges a list of ApplicationReports grouping by ApplicationId. Our current policy is to merge the application reports from the reachable SubClusters.
      Parameters:
      responses - a list of ApplicationResponse to merge
      returnPartialResult - if the merge ApplicationReports should contain partial result or not
      Returns:
      the merged ApplicationsResponse

    • mergeClusterNodesResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse mergeClusterNodesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse> responses)
      Merges a list of GetClusterNodesResponse.
      Parameters:
      responses - a list of GetClusterNodesResponse to merge.
      Returns:
      the merged GetClusterNodesResponse.

    • mergeNodesToLabelsResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse mergeNodesToLabelsResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse> responses)
      Merges a list of GetNodesToLabelsResponse.
      Parameters:
      responses - a list of GetNodesToLabelsResponse to merge.
      Returns:
      the merged GetNodesToLabelsResponse.

    • mergeLabelsToNodes

      public static org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse mergeLabelsToNodes(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse> responses)
      Merges a list of GetLabelsToNodesResponse.
      Parameters:
      responses - a list of GetLabelsToNodesResponse to merge.
      Returns:
      the merged GetLabelsToNodesResponse.

    • mergeClusterNodeLabelsResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse mergeClusterNodeLabelsResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse> responses)
      Merges a list of GetClusterNodeLabelsResponse.
      Parameters:
      responses - a list of GetClusterNodeLabelsResponse to merge.
      Returns:
      the merged GetClusterNodeLabelsResponse.

    • mergeQueueUserAcls

      public static org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse mergeQueueUserAcls(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse> responses)
      Merges a list of GetQueueUserAclsInfoResponse.
      Parameters:
      responses - a list of GetQueueUserAclsInfoResponse to merge.
      Returns:
      the merged GetQueueUserAclsInfoResponse.

    • mergeReservationsList

      public static org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse mergeReservationsList(Collection<org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse> responses)
      Merges a list of ReservationListResponse.
      Parameters:
      responses - a list of ReservationListResponse to merge.
      Returns:
      the merged ReservationListResponse.

    • mergeResourceTypes

      public static org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse mergeResourceTypes(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse> responses)
      Merges a list of GetAllResourceTypeInfoResponse.
      Parameters:
      responses - a list of GetAllResourceTypeInfoResponse to merge.
      Returns:
      the merged GetAllResourceTypeInfoResponse.

    • mergeQueues

      public static org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse mergeQueues(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse> responses)
      Merges a list of GetQueueInfoResponse.
      Parameters:
      responses - a list of GetQueueInfoResponse to merge.
      Returns:
      the merged GetQueueInfoResponse.

    • mergeClusterResourceProfilesResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse mergeClusterResourceProfilesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse> responses)
      Merges a list of GetAllResourceProfilesResponse.
      Parameters:
      responses - a list of GetAllResourceProfilesResponse to merge.
      Returns:
      the merged GetAllResourceProfilesResponse.

    • mergeClusterResourceProfileResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse mergeClusterResourceProfileResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse> responses)
      Merges a list of GetResourceProfileResponse.
      Parameters:
      responses - a list of GetResourceProfileResponse to merge.
      Returns:
      the merged GetResourceProfileResponse.

    • mergeAttributesToNodesResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse mergeAttributesToNodesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetAttributesToNodesResponse> responses)
      Merges a list of GetAttributesToNodesResponse.
      Parameters:
      responses - a list of GetAttributesToNodesResponse to merge.
      Returns:
      the merged GetAttributesToNodesResponse.

    • mergeClusterNodeAttributesResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse mergeClusterNodeAttributesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeAttributesResponse> responses)
      Merges a list of GetClusterNodeAttributesResponse.
      Parameters:
      responses - a list of GetClusterNodeAttributesResponse to merge.
      Returns:
      the merged GetClusterNodeAttributesResponse.

    • mergeNodesToAttributesResponse

      public static org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse mergeNodesToAttributesResponse(Collection<org.apache.hadoop.yarn.api.protocolrecords.GetNodesToAttributesResponse> responses)
      Merges a list of GetNodesToAttributesResponse.
      Parameters:
      responses - a list of GetNodesToAttributesResponse to merge.
      Returns:
      the merged GetNodesToAttributesResponse.