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();
}