Skip to content

Commit

Permalink
Fixing broken formatting in ParquetFilter
Browse files Browse the repository at this point in the history
  • Loading branch information
AndreSchumacher committed May 16, 2014
1 parent a86553b commit 7a78265
Showing 1 changed file with 39 additions and 20 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,11 +51,15 @@ object ParquetFilters {
case BooleanType =>
ComparisonFilter.createBooleanFilter(name, literal.value.asInstanceOf[Boolean], predicate)
case IntegerType =>
ComparisonFilter.createIntFilter(name, (x: Int) =>
x == literal.value.asInstanceOf[Int], predicate)
ComparisonFilter.createIntFilter(
name,
(x: Int) => x == literal.value.asInstanceOf[Int],
predicate)
case LongType =>
ComparisonFilter.createLongFilter(name, (x: Long) =>
x == literal.value.asInstanceOf[Long], predicate)
ComparisonFilter.createLongFilter(
name,
(x: Long) => x == literal.value.asInstanceOf[Long],
predicate)
case DoubleType =>
ComparisonFilter.createDoubleFilter(
name,
Expand All @@ -74,11 +78,15 @@ object ParquetFilters {
literal: Literal,
predicate: CatalystPredicate) = literal.dataType match {
case IntegerType =>
ComparisonFilter.createIntFilter(name, (x: Int) =>
x < literal.value.asInstanceOf[Int], predicate)
ComparisonFilter.createIntFilter(
name,
(x: Int) => x < literal.value.asInstanceOf[Int],
predicate)
case LongType =>
ComparisonFilter.createLongFilter(name, (x: Long) =>
x < literal.value.asInstanceOf[Long], predicate)
ComparisonFilter.createLongFilter(
name,
(x: Long) => x < literal.value.asInstanceOf[Long],
predicate)
case DoubleType =>
ComparisonFilter.createDoubleFilter(
name,
Expand All @@ -95,11 +103,15 @@ object ParquetFilters {
literal: Literal,
predicate: CatalystPredicate) = literal.dataType match {
case IntegerType =>
ComparisonFilter.createIntFilter(name, (x: Int) =>
x <= literal.value.asInstanceOf[Int], predicate)
ComparisonFilter.createIntFilter(
name,
(x: Int) => x <= literal.value.asInstanceOf[Int],
predicate)
case LongType =>
ComparisonFilter.createLongFilter(name, (x: Long) =>
x <= literal.value.asInstanceOf[Long], predicate)
ComparisonFilter.createLongFilter(
name,
(x: Long) => x <= literal.value.asInstanceOf[Long],
predicate)
case DoubleType =>
ComparisonFilter.createDoubleFilter(
name,
Expand All @@ -117,11 +129,15 @@ object ParquetFilters {
literal: Literal,
predicate: CatalystPredicate) = literal.dataType match {
case IntegerType =>
ComparisonFilter.createIntFilter(name, (x: Int) =>
x > literal.value.asInstanceOf[Int], predicate)
ComparisonFilter.createIntFilter(
name,
(x: Int) => x > literal.value.asInstanceOf[Int],
predicate)
case LongType =>
ComparisonFilter.createLongFilter(name, (x: Long) =>
x > literal.value.asInstanceOf[Long], predicate)
ComparisonFilter.createLongFilter(
name,
(x: Long) => x > literal.value.asInstanceOf[Long],
predicate)
case DoubleType =>
ComparisonFilter.createDoubleFilter(
name,
Expand All @@ -138,11 +154,14 @@ object ParquetFilters {
literal: Literal,
predicate: CatalystPredicate) = literal.dataType match {
case IntegerType =>
ComparisonFilter.createIntFilter(name, (x: Int) =>
x >= literal.value.asInstanceOf[Int], predicate)
ComparisonFilter.createIntFilter(
name, (x: Int) => x >= literal.value.asInstanceOf[Int],
predicate)
case LongType =>
ComparisonFilter.createLongFilter(name, (x: Long) =>
x >= literal.value.asInstanceOf[Long], predicate)
ComparisonFilter.createLongFilter(
name,
(x: Long) => x >= literal.value.asInstanceOf[Long],
predicate)
case DoubleType =>
ComparisonFilter.createDoubleFilter(
name,
Expand Down

0 comments on commit 7a78265

Please sign in to comment.