Class JsonReader

java/tools/src/java/org/apache/orc/tools/convert/JsonReader.java:58–446

import java.util.Map;

public class JsonReader implements RecordReader {

  private final TypeDescription schema;
  private final Iterator<JsonElement> parser;
  private final JsonConverter[] converters;
  private final long totalSize;
  private final FSDataInputStream input;
  private long rowNumber = 0;
  private final DateTimeFormatter dateTimeFormatter;
  private String unionTag = "tag";
  private String unionValue = "value";

  interface JsonConverter {
    void convert(JsonElement value, ColumnVector vect, int row);
  }

  static class BooleanColumnConverter implements JsonConverter {
    @Override
    public void convert(JsonElement value, ColumnVector vect, int row) {
      if (value == null || value.isJsonNull()) {
        vect.noNulls = false;
        vect.isNull[row] = true;
      } else {
        LongColumnVector vector = (LongColumnVector) vect;
        vector.vector[row] = value.getAsBoolean() ? 1 : 0;
      }
    }
  }

  static class LongColumnConverter implements JsonConverter {
    @Override
    public void convert(JsonElement value, ColumnVector vect, int row) {
      if (value == null || value.isJsonNull()) {
        vect.noNulls = false;
        vect.isNull[row] = true;
      } else {
        LongColumnVector vector = (LongColumnVector) vect;
        vector.vector[row] = value.getAsLong();
      }
    }
  }

  static class DoubleColumnConverter implements JsonConverter {
    @Override
    public void convert(JsonElement value, ColumnVector vect, int row) {
      if (value == null || value.isJsonNull()) {
        vect.noNulls = false;
        vect.isNull[row] = true;
      } else {
        DoubleColumnVector vector = (DoubleColumnVector) vect;
        vector.vector[row] = value.getAsDouble();
      }
    }
  }

  static class StringColumnConverter implements JsonConverter {
    @Override
    public void convert(JsonElement value, ColumnVector vect, int row) {