We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 34ccee0 commit 1e4555aCopy full SHA for 1e4555a
sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -1252,11 +1252,11 @@ class DataFrame private[sql](
1252
*/
1253
@scala.annotation.varargs
1254
def drop(colNames: String*): DataFrame = {
1255
- val remainingColumns = df.schema.filter(f => colNames.contains(f.name)).map(f=>Column(f.name))
1256
- if (remainingColumns.size == df.schema.size) {
+ val remainingCols = df.schema.filter(f => colNames.contains(f.name)).map(f=>Column(f.name))
+ if (remainingCols.size == df.schema.size) {
1257
this
1258
} else {
1259
- df.select(remainingColumns: _*)
+ df.select(remainingCols: _*)
1260
}
1261
1262
0 commit comments