Searched refs:windowExpressions (Results 1 – 5 of 5) sorted by relevance
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ |
| H A D | Analyzer.scala | 523 case oldVersion @ Window(windowExpressions, _, _, child)
526 (oldVersion, oldVersion.copy(windowExpressions = newAliases(windowExpressions)))
1808 val withWindow = addWindow(windowExpressions, withFilter)
1824 val withWindow = addWindow(windowExpressions, withAggregate)
1839 val withWindow = addWindow(windowExpressions, withProject)
2269 val windowExpressions = constant
2273 if (windowExpressions.size == 1 &&
2274 windowExpressions.head.timeColumn.resolved &&
2275 windowExpressions.head.checkInputDataTypes().isSuccess) {
2276 val window = windowExpressions.head
[all …]
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ |
| H A D | basicLogicalOperators.scala | 531 windowExpressions: Seq[NamedExpression],
537 child.output ++ windowExpressions.map(_.toAttribute)
539 def windowOutputSet: AttributeSet = AttributeSet(windowExpressions.map(_.toAttribute))
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ |
| H A D | Optimizer.scala | 465 windowExpressions = w.windowExpressions.filter(p.references.contains)))
468 case w: Window if w.windowExpressions.isEmpty => w.child
602 w1.copy(windowExpressions = we2 ++ we1, child = grandChild)
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/ |
| H A D | package.scala | 345 windowExpressions: Seq[NamedExpression],
348 Window(windowExpressions, partitionSpec, orderSpec, logicalPlan)
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/catalyst/ |
| H A D | SQLBuilder.scala | 399 (w.child.output ++ w.windowExpressions).map(_.sql).mkString(", "),
|