Class MaskFactory

java/core/src/java/org/apache/orc/impl/mask/MaskFactory.java:32–116

A mask factory framework that automatically builds a recursive mask. The subclass defines how to mask the primitive types and the factory builds a recursive tree of data masks that matches the schema tree.

 * builds a recursive tree of data masks that matches the schema tree.
 */
public abstract class MaskFactory {

  protected abstract DataMask buildBooleanMask(TypeDescription schema);
  protected abstract DataMask buildLongMask(TypeDescription schema);
  protected abstract DataMask buildDecimalMask(TypeDescription schema);
  protected abstract DataMask buildDoubleMask(TypeDescription schema);
  protected abstract DataMask buildStringMask(TypeDescription schema);
  protected abstract DataMask buildDateMask(TypeDescription schema);
  protected abstract DataMask buildTimestampMask(TypeDescription schema);
  protected abstract DataMask buildBinaryMask(TypeDescription schema);

  public DataMask build(TypeDescription schema,
                        DataMask.MaskOverrides overrides) {
    switch(schema.getCategory()) {
      case BOOLEAN:
        return buildBooleanMask(schema);
      case BYTE:
      case SHORT:
      case INT:
      case LONG:
        return buildLongMask(schema);
      case FLOAT:
      case DOUBLE:
        return buildDoubleMask(schema);
      case DECIMAL:
        return buildDecimalMask(schema);
      case STRING:
      case CHAR:
      case VARCHAR:
        return buildStringMask(schema);
      case TIMESTAMP:
      case TIMESTAMP_INSTANT:
        return buildTimestampMask(schema);
      case DATE:
        return buildDateMask(schema);
      case BINARY:
        return buildBinaryMask(schema);
      case UNION:
        return buildUnionMask(schema, overrides);
      case STRUCT:
        return buildStructMask(schema, overrides);
      case LIST:
        return buildListMask(schema, overrides);
      case MAP:
        return buildMapMask(schema, overrides);
      default:
        throw new IllegalArgumentException("Unhandled type " + schema);
    }
  }

  protected DataMask[] buildChildren(List<TypeDescription> children,
                                     DataMask.MaskOverrides overrides) {
    DataMask[] result = new DataMask[children.size()];
    for(int i = 0; i < result.length; ++i) {
      TypeDescription child = children.get(i);
      DataMaskDescription over = overrides.hasOverride(child);
      if (over != null) {
        result[i] = DataMask.Factory.build(over, child, overrides);