Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21921#discussion_r206944006
--- 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 --
ditto
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
