File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/core/v1.2/src/main/scala/org/apache/spark/sql/execution/datasources/orc Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -139,7 +139,7 @@ private[sql] object OrcFilters extends OrcFiltersBase {
139139 /**
140140 * Get PredicateLeafType which is corresponding to the given DataType.
141141 */
142- private def getPredicateLeafType (dataType : DataType ) = dataType match {
142+ private [sql] def getPredicateLeafType (dataType : DataType ) = dataType match {
143143 case BooleanType => PredicateLeaf .Type .BOOLEAN
144144 case ByteType | ShortType | IntegerType | LongType => PredicateLeaf .Type .LONG
145145 case FloatType | DoubleType => PredicateLeaf .Type .FLOAT
@@ -219,7 +219,7 @@ private[sql] object OrcFilters extends OrcFiltersBase {
219219 expression : Filter ,
220220 builder : Builder ): Option [Builder ] = {
221221 def getType (attribute : String ): PredicateLeaf .Type =
222- getPredicateLeafType(dataTypeMap(attribute))
222+ getPredicateLeafType(dataTypeMap(attribute).fieldType )
223223
224224 import org .apache .spark .sql .sources ._
225225
You can’t perform that action at this time.
0 commit comments