Skip to content

Commit 9a63611

Browse files
Yash DattaYash Datta
authored andcommitted
PARQUET-116: Fix whitespace
1 parent 7caa4dc commit 9a63611

12 files changed

Lines changed: 24 additions & 26 deletions

File tree

parquet-column/src/main/java/parquet/filter2/predicate/FilterApi.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -152,13 +152,15 @@ public static <T extends Comparable<T>, C extends Column<T> & SupportsLtGt> GtEq
152152
UserDefined<T, U> userDefined(Column<T> column, Class<U> clazz) {
153153
return new UserDefined<T, U>(column, clazz);
154154
}
155-
155+
156+
/**
157+
* Similar to above but allows to pass Serializable {@link UserDefinedPredicate}
158+
*/
156159
public static <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable>
157160
ConfiguredUserDefined<T, U> userDefined(Column<T> column, U udp) {
158161
return new ConfiguredUserDefined<T, U> (column, udp);
159162
}
160163

161-
162164
/**
163165
* Constructs the logical and of two predicates. Records will be kept if both the left and right predicate agree
164166
* that the record should be kept.

parquet-column/src/main/java/parquet/filter2/predicate/FilterPredicate.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import parquet.filter2.predicate.Operators.NotEq;
1616
import parquet.filter2.predicate.Operators.Or;
1717
import parquet.filter2.predicate.Operators.UserDefined;
18+
1819
/**
1920
* A FilterPredicate is an expression tree describing the criteria for which records to keep when loading data from
2021
* a parquet file. These predicates are applied in multiple places. Currently, they are applied to all row groups at
@@ -50,10 +51,10 @@ public static interface Visitor<R> {
5051
R visit(And and);
5152
R visit(Or or);
5253
R visit(Not not);
53-
<T extends Comparable<T>, U extends UserDefinedPredicate<T> > R visit(UserDefined<T, U> udp);
54-
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable > R visit(ConfiguredUserDefined<T, U> udp);
55-
<T extends Comparable<T>, U extends UserDefinedPredicate<T> > R visit(LogicalNotUserDefined<T, U> udp);
56-
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable > R visit(LogicalNotConfiguredUserDefined<T, U> udp);
54+
<T extends Comparable<T>, U extends UserDefinedPredicate<T>> R visit(UserDefined<T, U> udp);
55+
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable> R visit(ConfiguredUserDefined<T, U> udp);
56+
<T extends Comparable<T>, U extends UserDefinedPredicate<T>> R visit(LogicalNotUserDefined<T, U> udp);
57+
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable> R visit(LogicalNotConfiguredUserDefined<T, U> udp);
5758
}
5859

5960
}

parquet-column/src/main/java/parquet/filter2/predicate/LogicalInverseRewriter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public FilterPredicate visit(Not not) {
8888
}
8989

9090
@Override
91-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(UserDefined<T, U> udp) {
91+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(UserDefined<T, U> udp) {
9292
return udp;
9393
}
9494

@@ -98,7 +98,7 @@ public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializabl
9898
}
9999

100100
@Override
101-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
101+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
102102
return udp;
103103
}
104104

parquet-column/src/main/java/parquet/filter2/predicate/LogicalInverter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ public FilterPredicate visit(Not not) {
8383
}
8484

8585
@Override
86-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(UserDefined<T, U> udp) {
86+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(UserDefined<T, U> udp) {
8787
return new LogicalNotUserDefined<T, U>(udp);
8888
}
8989

@@ -93,7 +93,7 @@ public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializab
9393
}
9494

9595
@Override
96-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
96+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
9797
return udp.getUserDefined();
9898
}
9999

parquet-column/src/main/java/parquet/filter2/predicate/Operators.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -340,11 +340,10 @@ public int hashCode() {
340340
}
341341
}
342342

343-
public static final class UserDefined<T extends Comparable<T>, U extends UserDefinedPredicate<T> > implements FilterPredicate, Serializable {
343+
public static final class UserDefined<T extends Comparable<T>, U extends UserDefinedPredicate<T>> implements FilterPredicate, Serializable {
344344
private final Column<T> column;
345345
private final Class<U> udpClass;
346346
private final String toString;
347-
348347
private static final String INSTANTIATION_ERROR_MESSAGE =
349348
"Could not instantiate custom filter: %s. User defined predicates must be static classes with a default constructor.";
350349

parquet-column/src/main/java/parquet/filter2/predicate/SchemaCompatibilityValidator.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ public Void visit(Not not) {
131131
}
132132

133133
@Override
134-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Void visit(UserDefined<T, U> udp) {
134+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Void visit(UserDefined<T, U> udp) {
135135
validateColumn(udp.getColumn());
136136
return null;
137137
}
@@ -143,7 +143,7 @@ public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializabl
143143
}
144144

145145
@Override
146-
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Void visit(LogicalNotUserDefined<T, U> udp) {
146+
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Void visit(LogicalNotUserDefined<T, U> udp) {
147147
return udp.getUserDefined().accept(this);
148148
}
149149

parquet-column/src/main/java/parquet/filter2/predicate/UserDefinedPredicate.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
*/
1111
// TODO: consider avoiding autoboxing and adding the specialized methods for each type
1212
// TODO: downside is that's fairly unwieldy for users
13-
public abstract class UserDefinedPredicate<T extends Comparable<T> > {
13+
public abstract class UserDefinedPredicate<T extends Comparable<T>> {
1414
/**
1515
* A udp must have a default constructor.
1616
* The udp passed to {@link FilterApi} will not be serialized along with its state.
@@ -86,4 +86,4 @@ public UserDefinedPredicate() { }
8686
* }
8787
*/
8888
public abstract boolean inverseCanDrop(Statistics<T> statistics);
89-
}
89+
}

parquet-column/src/test/java/parquet/filter2/predicate/DummyUdp.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package parquet.filter2.predicate;
22

3-
import java.io.Serializable;
4-
53
public class DummyUdp extends UserDefinedPredicate<Integer> {
64

75
@Override

parquet-column/src/test/java/parquet/filter2/predicate/TestSchemaCompatibilityValidator.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package parquet.filter2.predicate;
22

3-
import java.io.Serializable;
43
import org.junit.Test;
54

65
import parquet.filter2.predicate.Operators.BinaryColumn;

parquet-generator/src/main/java/parquet/filter2/IncrementallyUpdatedFilterPredicateGenerator.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public void run() throws IOException {
110110
addVisitEnd();
111111

112112
add(" @Override\n" +
113-
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > IncrementallyUpdatedFilterPredicate visit(UserDefined<T, U> pred) {\n");
113+
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> IncrementallyUpdatedFilterPredicate visit(UserDefined<T, U> pred) {\n");
114114
addUdpBegin();
115115
for (TypeInfo info : TYPES) {
116116
addUdpCase(info, false);
@@ -126,7 +126,7 @@ public void run() throws IOException {
126126
addVisitEnd();
127127

128128
add(" @Override\n" +
129-
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > IncrementallyUpdatedFilterPredicate visit(LogicalNotUserDefined<T, U> notPred) {\n" +
129+
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> IncrementallyUpdatedFilterPredicate visit(LogicalNotUserDefined<T, U> notPred) {\n" +
130130
" UserDefined<T, U> pred = notPred.getUserDefined();\n");
131131
addUdpBegin();
132132
for (TypeInfo info : TYPES) {

0 commit comments

Comments
 (0)