Skip to content

Commit

Permalink
reformat
Browse files Browse the repository at this point in the history
  • Loading branch information
razajafri committed Oct 21, 2023
1 parent a4aac4a commit 19f18e6
Showing 1 changed file with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,15 +39,15 @@ trait Spark332PlusDBShims extends Spark321PlusDBShims {
override def ansiCastRule: ExprRule[_ <: Expression] = null

override def getParquetFilters(
schema: MessageType,
pushDownDate: Boolean,
pushDownTimestamp: Boolean,
pushDownDecimal: Boolean,
pushDownStartWith: Boolean,
pushDownInFilterThreshold: Int,
caseSensitive: Boolean,
lookupFileMeta: String => String,
dateTimeRebaseModeFromConf: String): ParquetFilters = {
schema: MessageType,
pushDownDate: Boolean,
pushDownTimestamp: Boolean,
pushDownDecimal: Boolean,
pushDownStartWith: Boolean,
pushDownInFilterThreshold: Int,
caseSensitive: Boolean,
lookupFileMeta: String => String,
dateTimeRebaseModeFromConf: String): ParquetFilters = {
val datetimeRebaseMode = DataSourceUtils
.datetimeRebaseSpec(lookupFileMeta, dateTimeRebaseModeFromConf)
new ParquetFilters(schema, pushDownDate, pushDownTimestamp, pushDownDecimal, pushDownStartWith,
Expand Down

0 comments on commit 19f18e6

Please sign in to comment.