parquet-common/src/main/java/org/apache/parquet/io/DelegatingSeekableInputStream.java
static int readHeapBuffer(InputStream f, ByteBuffer buf) throws IOException {
    int bytesRead = f.read(buf.array(), buf.arrayOffset() + buf.position(), buf.remaining());
    if (bytesRead < 0) {
      // if this resulted in EOF, don't update position
      return bytesRead;
    } else {
      buf.position(buf.position() + bytesRead);
      return bytesRead;
    }
  }
static int readHeapBuffer(InputStream f, ByteBuffer buf) throws IOException {
    int bytesRead = f.read(buf.array(), buf.arrayOffset() + buf.position(), buf.remaining());
    if (bytesRead < 0) {
      // if this resulted in EOF, don't update position
      return bytesRead;
    } else {
      buf.position(buf.position() + bytesRead);
      return bytesRead;
    }
  }
static int readHeapBuffer ( InputStream f , ByteBuffer buf ) throws IOException { int bytesRead = f . read ( buf . array ( ) , buf . arrayOffset ( ) + buf . position ( ) , buf . remaining ( ) ) ; if ( bytesRead < 0 ) { // if this resulted in EOF, don't update position return bytesRead ; } else { buf . position ( buf . position ( ) + bytesRead ) ; return bytesRead ; } }
Visible for testing
Visible for testing