File tree Expand file tree Collapse file tree 1 file changed +11
-6
lines changed
sql/core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +11
-6
lines changed Original file line number Diff line number Diff line change @@ -356,8 +356,9 @@ private[parquet] object ComparisonFilter {
356356 new BooleanPredicateFunction {
357357 def functionToApply (input : Boolean ): Boolean = input == value
358358 }
359- )),
359+ )),
360360 predicate)
361+
361362 def createStringFilter (
362363 columnName : String ,
363364 value : String ,
@@ -370,8 +371,9 @@ private[parquet] object ComparisonFilter {
370371 new ColumnPredicates .PredicateFunction [String ] {
371372 def functionToApply (input : String ): Boolean = input == value
372373 }
373- )),
374+ )),
374375 predicate)
376+
375377 def createIntFilter (
376378 columnName : String ,
377379 func : Int => Boolean ,
@@ -384,8 +386,9 @@ private[parquet] object ComparisonFilter {
384386 new IntegerPredicateFunction {
385387 def functionToApply (input : Int ) = func(input)
386388 }
387- )),
389+ )),
388390 predicate)
391+
389392 def createLongFilter (
390393 columnName : String ,
391394 func : Long => Boolean ,
@@ -398,8 +401,9 @@ private[parquet] object ComparisonFilter {
398401 new LongPredicateFunction {
399402 def functionToApply (input : Long ) = func(input)
400403 }
401- )),
404+ )),
402405 predicate)
406+
403407 def createDoubleFilter (
404408 columnName : String ,
405409 func : Double => Boolean ,
@@ -412,8 +416,9 @@ private[parquet] object ComparisonFilter {
412416 new DoublePredicateFunction {
413417 def functionToApply (input : Double ) = func(input)
414418 }
415- )),
419+ )),
416420 predicate)
421+
417422 def createFloatFilter (
418423 columnName : String ,
419424 func : Float => Boolean ,
@@ -426,6 +431,6 @@ private[parquet] object ComparisonFilter {
426431 new FloatPredicateFunction {
427432 def functionToApply (input : Float ) = func(input)
428433 }
429- )),
434+ )),
430435 predicate)
431436}
You can’t perform that action at this time.
0 commit comments