public void run()

in parquet-generator/src/main/java/org/apache/parquet/filter2/IncrementallyUpdatedFilterPredicateGenerator.java [67:180]


  public void run() throws IOException {
    add("package org.apache.parquet.filter2.recordlevel;\n" + "\n"
        + "import java.util.Iterator;\n"
        + "import java.util.List;\n"
        + "import java.util.Set;\n"
        + "\n"
        + "import org.apache.parquet.hadoop.metadata.ColumnPath;\n"
        + "import org.apache.parquet.filter2.predicate.FilterPredicate;\n"
        + "import org.apache.parquet.filter2.predicate.Operators;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.Contains;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.Eq;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.Gt;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.GtEq;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.In;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.LogicalNotUserDefined;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.Lt;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.LtEq;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.NotEq;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.NotIn;\n"
        + "import org.apache.parquet.filter2.predicate.Operators.UserDefined;\n"
        + "import org.apache.parquet.filter2.predicate.UserDefinedPredicate;\n"
        + "import org.apache.parquet.filter2.recordlevel.IncrementallyUpdatedFilterPredicate.ValueInspector;\n"
        + "import org.apache.parquet.filter2.recordlevel.IncrementallyUpdatedFilterPredicate.DelegatingValueInspector;\n"
        + "import org.apache.parquet.io.api.Binary;\n"
        + "import org.apache.parquet.io.PrimitiveColumnIO;\n"
        + "import org.apache.parquet.schema.PrimitiveComparator;\n\n"
        + "/**\n"
        + " * This class is auto-generated by org.apache.parquet.filter2.IncrementallyUpdatedFilterPredicateGenerator\n"
        + " * Do not manually edit!\n"
        + " * See {@link IncrementallyUpdatedFilterPredicateBuilderBase}\n"
        + " */\n");

    add(
        "public class IncrementallyUpdatedFilterPredicateBuilder extends IncrementallyUpdatedFilterPredicateBuilderBase {\n\n");

    add("  public IncrementallyUpdatedFilterPredicateBuilder(List<PrimitiveColumnIO> leaves) {\n"
        + "    super(leaves);\n"
        + "  }\n\n");

    addVisitBegin("Eq");
    for (TypeInfo info : TYPES) {
      addEqNotEqCase(info, true, false);
    }
    addVisitEnd();

    addVisitBegin("NotEq");
    for (TypeInfo info : TYPES) {
      addEqNotEqCase(info, false, false);
    }
    addVisitEnd();

    addVisitBegin("In");
    for (TypeInfo info : TYPES) {
      addInNotInCase(info, true, false);
    }
    addVisitEnd();

    addVisitBegin("NotIn");
    for (TypeInfo info : TYPES) {
      addInNotInCase(info, false, false);
    }
    addVisitEnd();

    addContainsBegin();
    addVisitBegin("Contains");
    addContainsCase();
    addContainsEnd();
    addVisitEnd();

    addVisitBegin("Lt");
    for (TypeInfo info : TYPES) {
      addInequalityCase(info, "<", false);
    }
    addVisitEnd();

    addVisitBegin("LtEq");
    for (TypeInfo info : TYPES) {
      addInequalityCase(info, "<=", false);
    }
    addVisitEnd();

    addVisitBegin("Gt");
    for (TypeInfo info : TYPES) {
      addInequalityCase(info, ">", false);
    }
    addVisitEnd();

    addVisitBegin("GtEq");
    for (TypeInfo info : TYPES) {
      addInequalityCase(info, ">=", false);
    }
    addVisitEnd();

    add(
        "  @Override\n"
            + "  public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> IncrementallyUpdatedFilterPredicate visit(UserDefined<T, U> pred) {\n");
    addUdpBegin();
    for (TypeInfo info : TYPES) {
      addUdpCase(info, false);
    }
    addVisitEnd();

    add("  @Override\n"
        + "  public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> IncrementallyUpdatedFilterPredicate visit(LogicalNotUserDefined<T, U> notPred) {\n"
        + "    UserDefined<T, U> pred = notPred.getUserDefined();\n");
    addUdpBegin();
    for (TypeInfo info : TYPES) {
      addUdpCase(info, true);
    }
    addVisitEnd();

    add("}\n");
    writer.close();
  }