Skip to content

Commit

Permalink
address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
sfc-gh-bli committed Nov 21, 2023
1 parent d923d71 commit 27e331e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main/scala/com/snowflake/snowpark/DataFrame.scala
Original file line number Diff line number Diff line change
Expand Up @@ -564,7 +564,7 @@ class DataFrame private[snowpark] (
// todo: error message
val tf = columns.filter(_.expr.isInstanceOf[TableFunctionExpression])
tf.size match {
case 0 =>
case 0 => // no table function
val resultDF = withPlan {
Project(columns.map(_.named), plan)
}
Expand All @@ -579,7 +579,7 @@ class DataFrame private[snowpark] (
} else {
renameBackIfDeduped(resultDF)
}
case 1 =>
case 1 => // 1 table function
val base = this.join(tf.head)
val baseColumns = base.schema.map(field => base(field.name))
val inputDFColumnSize = this.schema.size
Expand Down

0 comments on commit 27e331e

Please sign in to comment.