Home
last modified time | relevance | path

Searched refs:unhandledPredicates (Results 1 – 1 of 1) sorted by relevance

/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/
H A DDataSourceStrategy.scala415 val (unhandledPredicates, pushedFilters, handledFilters) =
421 val handledPredicates = filterPredicates.filterNot(unhandledPredicates.contains)
422 val unhandledSet = AttributeSet(unhandledPredicates.flatMap(_.references))
429 val filterCondition = unhandledPredicates.reduceLeftOption(expressions.And)
616 val unhandledPredicates = translatedMap.filter { case (p, f) => constant
621 (nonconvertiblePredicates ++ unhandledPredicates, pushedFilters, handledFilters)