public SamzaResourceRequest peekPendingRequest() {
    synchronized (lock) {
      return requestsQueue.peek();
    }
  }
Retrieves, but does not remove, the next pending request in the queue.

@return  the pending request or {@code null} if there is no pending request.
samza-core/src/main/java/org/apache/samza/clustermanager/ResourceRequestState.java