Skip to content

Commit

Permalink
PARQUET-116: Fix whitespace
Browse files Browse the repository at this point in the history
  • Loading branch information
Yash Datta authored and Yash Datta committed Feb 2, 2015
1 parent 7caa4dc commit 9a63611
Show file tree
Hide file tree
Showing 12 changed files with 24 additions and 26 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -152,13 +152,15 @@ public static <T extends Comparable<T>, C extends Column<T> & SupportsLtGt> GtEq
UserDefined<T, U> userDefined(Column<T> column, Class<U> clazz) {
return new UserDefined<T, U>(column, clazz);
}


/**
* Similar to above but allows to pass Serializable {@link UserDefinedPredicate}
*/
public static <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable>
ConfiguredUserDefined<T, U> userDefined(Column<T> column, U udp) {
return new ConfiguredUserDefined<T, U> (column, udp);
}


/**
* Constructs the logical and of two predicates. Records will be kept if both the left and right predicate agree
* that the record should be kept.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
import parquet.filter2.predicate.Operators.NotEq;
import parquet.filter2.predicate.Operators.Or;
import parquet.filter2.predicate.Operators.UserDefined;

/**
* A FilterPredicate is an expression tree describing the criteria for which records to keep when loading data from
* a parquet file. These predicates are applied in multiple places. Currently, they are applied to all row groups at
Expand Down Expand Up @@ -50,10 +51,10 @@ public static interface Visitor<R> {
R visit(And and);
R visit(Or or);
R visit(Not not);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> > R visit(UserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable > R visit(ConfiguredUserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> > R visit(LogicalNotUserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable > R visit(LogicalNotConfiguredUserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T>> R visit(UserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable> R visit(ConfiguredUserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T>> R visit(LogicalNotUserDefined<T, U> udp);
<T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable> R visit(LogicalNotConfiguredUserDefined<T, U> udp);
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ public FilterPredicate visit(Not not) {
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(UserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(UserDefined<T, U> udp) {
return udp;
}

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

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
return udp;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ public FilterPredicate visit(Not not) {
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(UserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(UserDefined<T, U> udp) {
return new LogicalNotUserDefined<T, U>(udp);
}

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

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> FilterPredicate visit(LogicalNotUserDefined<T, U> udp) {
return udp.getUserDefined();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -340,11 +340,10 @@ public int hashCode() {
}
}

public static final class UserDefined<T extends Comparable<T>, U extends UserDefinedPredicate<T> > implements FilterPredicate, Serializable {
public static final class UserDefined<T extends Comparable<T>, U extends UserDefinedPredicate<T>> implements FilterPredicate, Serializable {
private final Column<T> column;
private final Class<U> udpClass;
private final String toString;

private static final String INSTANTIATION_ERROR_MESSAGE =
"Could not instantiate custom filter: %s. User defined predicates must be static classes with a default constructor.";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ public Void visit(Not not) {
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Void visit(UserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Void visit(UserDefined<T, U> udp) {
validateColumn(udp.getColumn());
return null;
}
Expand All @@ -143,7 +143,7 @@ public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializabl
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Void visit(LogicalNotUserDefined<T, U> udp) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Void visit(LogicalNotUserDefined<T, U> udp) {
return udp.getUserDefined().accept(this);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
*/
// TODO: consider avoiding autoboxing and adding the specialized methods for each type
// TODO: downside is that's fairly unwieldy for users
public abstract class UserDefinedPredicate<T extends Comparable<T> > {
public abstract class UserDefinedPredicate<T extends Comparable<T>> {
/**
* A udp must have a default constructor.
* The udp passed to {@link FilterApi} will not be serialized along with its state.
Expand Down Expand Up @@ -86,4 +86,4 @@ public UserDefinedPredicate() { }
* }
*/
public abstract boolean inverseCanDrop(Statistics<T> statistics);
}
}
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
package parquet.filter2.predicate;

import java.io.Serializable;

public class DummyUdp extends UserDefinedPredicate<Integer> {

@Override
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package parquet.filter2.predicate;

import java.io.Serializable;
import org.junit.Test;

import parquet.filter2.predicate.Operators.BinaryColumn;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ public void run() throws IOException {
addVisitEnd();

add(" @Override\n" +
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > IncrementallyUpdatedFilterPredicate visit(UserDefined<T, U> pred) {\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);
Expand All @@ -126,7 +126,7 @@ public void run() throws IOException {
addVisitEnd();

add(" @Override\n" +
" public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > IncrementallyUpdatedFilterPredicate visit(LogicalNotUserDefined<T, U> notPred) {\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) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -219,7 +219,7 @@ public Boolean visit(Not not) {
"This predicate contains a not! Did you forget to run this predicate through LogicalInverseRewriter? " + not);
}

private <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Boolean visit(UserDefined<T, U> ud, boolean inverted) {
private <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Boolean visit(UserDefined<T, U> ud, boolean inverted) {
Column<T> filterColumn = ud.getColumn();
ColumnChunkMetaData columnChunk = getColumnChunk(filterColumn.getColumnPath());
U udp = ud.getUserDefinedPredicate();
Expand Down Expand Up @@ -250,7 +250,7 @@ private <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializab
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Boolean visit(UserDefined<T, U> ud) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Boolean visit(UserDefined<T, U> ud) {
return visit(ud, false);
}

Expand All @@ -260,12 +260,12 @@ public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializabl
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> > Boolean visit(LogicalNotUserDefined<T, U> lnud) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T>> Boolean visit(LogicalNotUserDefined<T, U> lnud) {
return visit(lnud.getUserDefined(), true);
}

@Override
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable > Boolean visit(LogicalNotConfiguredUserDefined<T, U> lnud) {
public <T extends Comparable<T>, U extends UserDefinedPredicate<T> & Serializable> Boolean visit(LogicalNotConfiguredUserDefined<T, U> lnud) {
return visit(lnud.getUserDefined(), true);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import java.io.Serializable;

import org.junit.Test;

Expand Down

0 comments on commit 9a63611

Please sign in to comment.