@Override
  public int readInt()
      throws EOFException {
    if (availableLong() < 4) {
      throw new EOFException();
    }
    int result = _dataBuffer.getInt(_currentOffset);
    _currentOffset += 4;
    return result;
  }
@Test
  void testReadInt()
      throws EOFException {
    int read = _dataBufferPinotInputStream.readInt();

    assertEquals(read, _byteBuffer.getInt(0));
    assertEquals(_dataBufferPinotInputStream.getCurrentOffset(), Integer.BYTES);
  }