Skip to content

Commit

Permalink
fix compilation issue
Browse files Browse the repository at this point in the history
  • Loading branch information
timvw committed Nov 8, 2023
1 parent bba670a commit b748751
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import org.apache.spark.sql.execution.datasources.PathFilterFactory
import org.apache.spark.sql.types.StructType
import org.apache.spark.sql.util.CaseInsensitiveStringMap

import java.util
import scala.collection.JavaConverters._

case class DatafeedTable(name: String,
Expand Down Expand Up @@ -41,7 +40,7 @@ case class DatafeedTable(name: String,
StructType(fieldsWhichCanBeContributed)
}

override def capabilities(): util.Set[TableCapability] = Set(TableCapability.BATCH_READ).asJava
override def capabilities(): java.util.Set[TableCapability] = Set(TableCapability.BATCH_READ).asJava

override def newScanBuilder(options: CaseInsensitiveStringMap): ScanBuilder = {
DatafeedScanBuilder(sparkSession, this.options, manifestFiles, schema)
Expand Down

0 comments on commit b748751

Please sign in to comment.