in java/core/src/java/org/apache/orc/impl/TypeUtils.java [40:105]
public static ColumnVector createColumn(TypeDescription schema,
TypeDescription.RowBatchVersion version,
int maxSize) {
switch (schema.getCategory()) {
case BOOLEAN:
case BYTE:
case SHORT:
case INT:
case LONG:
return new LongColumnVector(maxSize);
case DATE:
return new DateColumnVector(maxSize);
case TIMESTAMP:
case TIMESTAMP_INSTANT:
return new TimestampColumnVector(maxSize);
case FLOAT:
case DOUBLE:
return new DoubleColumnVector(maxSize);
case DECIMAL: {
int precision = schema.getPrecision();
int scale = schema.getScale();
if (version == TypeDescription.RowBatchVersion.ORIGINAL ||
precision > TypeDescription.MAX_DECIMAL64_PRECISION) {
return new DecimalColumnVector(maxSize, precision, scale);
} else {
return new Decimal64ColumnVector(maxSize, precision, scale);
}
}
case STRING:
case BINARY:
case CHAR:
case VARCHAR:
return new BytesColumnVector(maxSize);
case STRUCT: {
List<TypeDescription> children = schema.getChildren();
ColumnVector[] fieldVector = new ColumnVector[children.size()];
for(int i=0; i < fieldVector.length; ++i) {
fieldVector[i] = createColumn(children.get(i), version, maxSize);
}
return new StructColumnVector(maxSize,
fieldVector);
}
case UNION: {
List<TypeDescription> children = schema.getChildren();
ColumnVector[] fieldVector = new ColumnVector[children.size()];
for(int i=0; i < fieldVector.length; ++i) {
fieldVector[i] = createColumn(children.get(i), version, maxSize);
}
return new UnionColumnVector(maxSize,
fieldVector);
}
case LIST: {
List<TypeDescription> children = schema.getChildren();
return new ListColumnVector(maxSize,
createColumn(children.get(0), version, maxSize));
}
case MAP: {
List<TypeDescription> children = schema.getChildren();
return new MapColumnVector(maxSize,
createColumn(children.get(0), version, maxSize),
createColumn(children.get(1), version, maxSize));
}
default:
throw new IllegalArgumentException("Unknown type " + schema.getCategory());
}
}