File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
main/scala/org/apache/spark/sql
test/scala/org/apache/spark/sql/connector Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -40,5 +40,5 @@ trait V1Scan extends Scan {
4040 *
4141 * @since 3.0.0
4242 */
43- def toV1Relation (context : SQLContext ): BaseRelation
43+ def toV1TableScan (context : SQLContext ): BaseRelation
4444}
Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ class DataSourceV2Strategy(session: SparkSession) extends Strategy with Predicat
4747
4848 val (scanExec, needsUnsafeConversion) = relation.scan match {
4949 case v1Scan : V1Scan =>
50- val v1Relation = v1Scan.toV1Relation (session.sqlContext)
50+ val v1Relation = v1Scan.toV1TableScan (session.sqlContext)
5151 if (v1Relation.schema != v1Scan.readSchema()) {
5252 throw new IllegalArgumentException (
5353 " The fallback v1 relation reports inconsistent schema:\n " +
Original file line number Diff line number Diff line change @@ -164,7 +164,7 @@ class TableWithV1ReadFallback(override val name: String) extends Table with Supp
164164 requiredSchema : StructType ,
165165 filters : Array [Filter ]) extends V1Scan {
166166 override def readSchema (): StructType = requiredSchema
167- override def toV1Relation (context : SQLContext ): BaseRelation = {
167+ override def toV1TableScan (context : SQLContext ): BaseRelation = {
168168 new BaseRelation with TableScan {
169169 override def sqlContext : SQLContext = context
170170 override def schema : StructType = requiredSchema
You can’t perform that action at this time.
0 commit comments