Class ReaderImpl

java/core/src/java/org/apache/orc/impl/ReaderImpl.java:64–1160

import java.util.function.Supplier;

public class ReaderImpl implements Reader {

  private static final Logger LOG = LoggerFactory.getLogger(ReaderImpl.class);

  private static final OrcFile.Version[] ORC_FILE_VERSION_VALUES = OrcFile.Version.values();
  private static final OrcFile.WriterVersion[] ORC_FILE_WRITER_VERSION_VALUES
      = OrcFile.WriterVersion.values();

  private static final int DIRECTORY_SIZE_GUESS = 16 * 1024;
  public static final int DEFAULT_COMPRESSION_BLOCK_SIZE = 256 * 1024;

  private final long maxLength;
  protected final Path path;
  protected final OrcFile.ReaderOptions options;
  protected final org.apache.orc.CompressionKind compressionKind;
  protected FSDataInputStream file;
  protected int bufferSize;
  // the unencrypted stripe statistics or null if they haven't been read yet
  protected List<OrcProto.StripeStatistics> stripeStatistics;
  private final int metadataSize;
  protected final List<OrcProto.Type> types;
  private final TypeDescription schema;
  private final List<OrcProto.UserMetadataItem> userMetadata;
  private final List<OrcProto.ColumnStatistics> fileStats;
  private final List<StripeInformation> stripes;
  protected final int rowIndexStride;
  private final long contentLength, numberOfRows;
  private final ReaderEncryption encryption;

  private long deserializedSize = -1;
  protected final Configuration conf;
  protected final boolean useUTCTimestamp;
  private final List<Integer> versionList;
  private final OrcFile.WriterVersion writerVersion;
  private final String softwareVersion;

  protected final OrcTail tail;

  public static class StripeInformationImpl
      implements StripeInformation {
    private final long stripeId;
    private final long originalStripeId;
    private final byte[][] encryptedKeys;
    private final OrcProto.StripeInformation stripe;

    public StripeInformationImpl(OrcProto.StripeInformation stripe,
                                 long stripeId,
                                 long previousOriginalStripeId,
                                 byte[][] previousKeys) {
      this.stripe = stripe;
      this.stripeId = stripeId;
      if (stripe.hasEncryptStripeId()) {
        originalStripeId = stripe.getEncryptStripeId();
      } else {
        originalStripeId = previousOriginalStripeId + 1;
      }
      if (stripe.getEncryptedLocalKeysCount() != 0) {
        encryptedKeys = new byte[stripe.getEncryptedLocalKeysCount()][];