@Override
  public BrokerResponse executeQuery(String brokerAddress, String query)
      throws PinotClientException {
    try {
      return executeQueryAsync(brokerAddress, query).get(_brokerReadTimeout, TimeUnit.MILLISECONDS);
    } catch (Exception e) {
      throw new PinotClientException(e);
    }
  }
@Test
  public void validJsonResponse() {
    _responseJson = _VALID_RESPONSE_JSON;
    JsonAsyncHttpPinotClientTransportFactory factory = new JsonAsyncHttpPinotClientTransportFactory();
    JsonAsyncHttpPinotClientTransport transport = (JsonAsyncHttpPinotClientTransport) factory.buildTransport();
    BrokerResponse response =
        transport.executeQuery("localhost:" + _dummyServer.getAddress().getPort(), "select * from planets");
    assertFalse(response.hasExceptions());
    assertEquals(response.getRequestId(), "4567");
    ExecutionStats stats = response.getExecutionStats();
    assertEquals(stats.getTotalDocs(), 115545);
    assertEquals(stats.getNumServersResponded(), 99);
  }