Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/21921#discussion_r206946259
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamMicroBatchReader.scala
---
@@ -169,7 +170,7 @@ class RateStreamMicroBatchReader(options:
DataSourceOptions, checkpointLocation:
(0 until numPartitions).map { p =>
new RateStreamMicroBatchInputPartition(
p, numPartitions, rangeStart, rangeEnd, localStartTimeMs,
relativeMsPerValue)
- : InputPartition[Row]
+ : InputPartition[InternalRow]
--- End diff --
This is fine since it isn't a cast, but it's generally better to check
whether these are still necessary after refactoring.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
