public void run()

in parquet-generator/src/main/java/org/apache/parquet/filter2/IncrementallyUpdatedFilterPredicateGenerator.java [66:167]
89 lines of code
11 McCabe index (conditional complexity)

  public void run() throws IOException {
    add("package org.apache.parquet.filter2.recordlevel;\n" +
        "\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.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.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);
    }
    addVisitEnd();

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

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

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

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

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

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

    addVisitBegin("GtEq");
    for (TypeInfo info : TYPES) {
      addInequalityCase(info, ">=");
    }
    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();
  }