Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/21921#discussion_r206936701
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/sources/v2/DataSourceV2Suite.scala
---
@@ -456,57 +445,20 @@ class AdvancedInputPartition(start: Int, end: Int,
requiredSchema: StructType)
current < end
}
- override def get(): Row = {
+ override def get(): InternalRow = {
val values = requiredSchema.map(_.name).map {
case "i" => current
case "j" => -current
}
- Row.fromSeq(values)
+ InternalRow.fromSeq(values)
}
}
-class UnsafeRowDataSourceV2 extends DataSourceV2 with ReadSupport {
--- End diff --
These aren't Row implementations. Why remove them?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
