Skip to content

Commit d7c67da

Browse files
committed
nit
1 parent 763e544 commit d7c67da

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ColumnResolutionHelper.scala

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -561,10 +561,11 @@ trait ColumnResolutionHelper extends Logging with DataTypeErrorsBase {
561561
// 4, if the matching node is found, but can not resolve the column, also fails with
562562
// 'CANNOT_RESOLVE_DATAFRAME_COLUMN';
563563
// 5, resolve the expression against the target node, the resolved attribute will be
564-
// filtered by the output attributes of nodes in the path (from root to matching node);
565-
// 6. if more than one resolved attributes are found in the above process, fails with
566-
// 'AMBIGUOUS_COLUMN_REFERENCE'.
567-
// 7. if the resolved attributes are all filtered out, return the original expression as it is.
564+
// filtered by the output attributes of nodes in the path (from matching to root node);
565+
// 6. if more than one resolved attributes are found in the above recursive process,
566+
// fails with 'AMBIGUOUS_COLUMN_REFERENCE'.
567+
// 7. if all the resolved attributes are filtered out, return the original expression
568+
// as it is.
568569
private def tryResolveDataFrameColumns(
569570
e: Expression,
570571
q: Seq[LogicalPlan]): Expression = e match {

0 commit comments

Comments
 (0)