Skip to content

Commit 07dd372

Browse files
committed
Fix format
1 parent e7b4ec9 commit 07dd372

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilters.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,7 @@ private[parquet] class ParquetFilters(pushDownDate: Boolean, pushDownStartWith:
7676
binaryColumn(n),
7777
Option(v).map(b => Binary.fromReusedByteArray(v.asInstanceOf[Array[Byte]])).orNull)
7878
// DateType
79-
case ParquetSchemaType(DATE, INT32, null)
80-
if pushDownDate =>
79+
case ParquetSchemaType(DATE, INT32, null) if pushDownDate =>
8180
(n: String, v: Any) => FilterApi.eq(
8281
intColumn(n),
8382
Option(v).map(date => dateToDays(date.asInstanceOf[Date]).asInstanceOf[Integer]).orNull)

sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ case class StringStartsWith(attribute: String, value: String) extends Filter {
199199

200200
/**
201201
* A filter that evaluates to `true` iff the attribute evaluates to
202-
* a string that starts with `value`.
202+
* a string that ends with `value`.
203203
*
204204
* @since 1.3.1
205205
*/

0 commit comments

Comments
 (0)