Class InStream

java/core/src/java/org/apache/orc/impl/InStream.java:39–922

import java.util.function.Consumer;

public abstract class InStream extends InputStream {

  private static final Logger LOG = LoggerFactory.getLogger(InStream.class);
  public static final int PROTOBUF_MESSAGE_MAX_LIMIT = 1024 << 20; // 1GB

  protected final Object name;
  protected final long offset;
  protected long length;
  protected DiskRangeList bytes;
  // position in the stream (0..length)
  protected long position;

  public InStream(Object name, long offset, long length) {
    this.name = name;
    this.offset = offset;
    this.length = length;
  }

  @Override
  public String toString() {
    return name.toString();
  }

  @Override
  public abstract void close();

  /**
   * Set the current range
   * @param newRange the block that is current
   * @param isJump if this was a seek instead of a natural read
   */
  protected abstract void setCurrent(DiskRangeList newRange,
                                     boolean isJump);
  /**
   * Reset the input to a new set of data.
   * @param input the input data
   */
  protected void reset(DiskRangeList input) {
    bytes = input;
    while (input != null &&
               (input.getEnd() <= offset ||
                    input.getOffset() > offset + length)) {
      input = input.next;
    }
    if (input == null || input.getOffset() <= offset) {
      position = 0;
    } else {
      position = input.getOffset() - offset;
    }
    setCurrent(input, true);
  }

  /**
   * Reset the input to a new set of data with a different length.
   *
   * in some cases, after resetting an UncompressedStream, its actual length is longer than its initial length.
   * Prior to ORC-516, InStream.UncompressedStream class had the 'length' field and the length was modifiable in
   * the reset() method. It was used in SettableUncompressedStream class in setBuffers() method.