Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20097#discussion_r159556678
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamSourceV2.scala
---
@@ -32,13 +32,17 @@ import
org.apache.spark.sql.sources.v2.DataSourceV2Options
import org.apache.spark.sql.sources.v2.reader._
import org.apache.spark.sql.sources.v2.streaming.reader.{MicroBatchReader,
Offset}
import org.apache.spark.sql.types.{LongType, StructField, StructType,
TimestampType}
-import org.apache.spark.util.SystemClock
+import org.apache.spark.util.{ManualClock, SystemClock}
class RateStreamV2Reader(options: DataSourceV2Options)
--- End diff --
Can you rename this to MicroBatchRateStreamReader, to make it consistent
with ContinuousRateStreamReader?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
