parquet-common/src/main/java/org/apache/parquet/io/DelegatingSeekableInputStream.java
static void readFullyDirectBuffer(InputStream f, ByteBuffer buf, byte[] temp) throws IOException {
    int nextReadLength = Math.min(buf.remaining(), temp.length);
    int bytesRead = 0;

    while (nextReadLength > 0 && (bytesRead = f.read(temp, 0, nextReadLength)) >= 0) {
      buf.put(temp, 0, bytesRead);
      nextReadLength = Math.min(buf.remaining(), temp.length);
    }

    if (bytesRead < 0 && buf.remaining() > 0) {
      throw new EOFException(
          "Reached the end of stream with " + buf.remaining() + " bytes left to read");
    }
  }
static void readFullyDirectBuffer(InputStream f, ByteBuffer buf, byte[] temp) throws IOException {
    int nextReadLength = Math.min(buf.remaining(), temp.length);
    int bytesRead = 0;

    while (nextReadLength > 0 && (bytesRead = f.read(temp, 0, nextReadLength)) >= 0) {
      buf.put(temp, 0, bytesRead);
      nextReadLength = Math.min(buf.remaining(), temp.length);
    }

    if (bytesRead < 0 && buf.remaining() > 0) {
      throw new EOFException(
          "Reached the end of stream with " + buf.remaining() + " bytes left to read");
    }
  }
static void readFullyDirectBuffer ( InputStream f , ByteBuffer buf , byte [ ] temp ) throws IOException { int nextReadLength = Math . min ( buf . remaining ( ) , temp . length ) ; int bytesRead = 0 ; while ( nextReadLength > 0 && ( bytesRead = f . read ( temp , 0 , nextReadLength ) ) >= 0 ) { buf . put ( temp , 0 , bytesRead ) ; nextReadLength = Math . min ( buf . remaining ( ) , temp . length ) ; } if ( bytesRead < 0 && buf . remaining ( ) > 0 ) { throw new EOFException ( "Reached the end of stream with " + buf . remaining ( ) + " bytes left to read" ) ; } }
Visible for testing
Visible for testing