@Override
  public short readShort()
      throws EOFException {
    if (availableLong() < 2) {
      throw new EOFException();
    }
    short result = _dataBuffer.getShort(_currentOffset);
    _currentOffset += 2;
    return result;
  }
@Test
  void testReadShort()
      throws EOFException {
    short read = _dataBufferPinotInputStream.readShort();

    assertEquals(read, _byteBuffer.getShort(0));
    assertEquals(_dataBufferPinotInputStream.getCurrentOffset(), Short.BYTES);
  }