Skip to content

Commit 38df669

Browse files
committed
Got rid of IntelliJ problems.
1 parent 23b2c2d commit 38df669

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ package org.apache.spark.sql.sources
2020
import org.apache.spark.rdd.RDD
2121
import org.apache.spark.sql.{Row, Strategy}
2222
import org.apache.spark.sql.catalyst.expressions
23-
import org.apache.spark.sql.catalyst.expressions._
23+
import org.apache.spark.sql.catalyst.expressions.{And, Attribute, AttributeReference, AttributeSet, Expression, NamedExpression}
2424
import org.apache.spark.sql.catalyst.planning.PhysicalOperation
2525
import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
2626
import org.apache.spark.sql.execution
@@ -111,6 +111,7 @@ private[sql] object DataSourceStrategy extends Strategy {
111111
}
112112
}
113113

114+
/** Turn Catalyst [[Expression]]s into data source [[Filter]]s. */
114115
protected[sql] def selectFilters(filters: Seq[Expression]): Seq[Filter] = filters.collect {
115116
case expressions.EqualTo(a: Attribute, expressions.Literal(v, _)) => EqualTo(a.name, v)
116117
case expressions.EqualTo(expressions.Literal(v, _), a: Attribute) => EqualTo(a.name, v)

0 commit comments

Comments
 (0)