Skip to content

Commit

Permalink
cleanup imports
Browse files Browse the repository at this point in the history
  • Loading branch information
scottsand-db committed Mar 25, 2024
1 parent 35a73df commit 036f5bd
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 7 deletions.
2 changes: 0 additions & 2 deletions spark/src/shims/spark-3.5/UnresolvedTableShim.scala
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@

package org.apache.spark.sql.catalyst.analysis

import org.apache.spark.sql.catalyst.analysis.UnresolvedTable

object UnresolvedTableShim {
def createUnresolvedTable(
tableNameParts: Seq[String],
Expand Down
3 changes: 1 addition & 2 deletions spark/src/shims/spark-4.0/ColumnDefinitionShim.scala
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,7 @@
package org.apache.spark.sql.catalyst.plans.logical

import org.apache.spark.sql.catalyst.parser.ParserInterface
import org.apache.spark.sql.catalyst.plans.logical.ColumnDefinition
import org.apache.spark.sql.types.{StructField, StructType}
import org.apache.spark.sql.types.StructField

object ColumnDefinitionShim {
def parseColumns(columns: Seq[StructField], sqlParser: ParserInterface): Seq[ColumnDefinition] = {
Expand Down
4 changes: 1 addition & 3 deletions spark/src/shims/spark-4.0/UnresolvedTableShim.scala
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,11 @@

package org.apache.spark.sql.catalyst.analysis

import org.apache.spark.sql.catalyst.analysis.UnresolvedTable

object UnresolvedTableShim {
def createUnresolvedTable(
tableNameParts: Seq[String],
commandName: String,
relationTypeMismatchHint: Option[String] = None): UnresolvedTable = {
UnresolvedTable(tableNameParts, commandName)
UnresolvedTable(tableNameParts, commandName) // Spark 4.0 doesn't take relationTypeMismatchHint
}
}

0 comments on commit 036f5bd

Please sign in to comment.