We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6ec51cf commit 32b389eCopy full SHA for 32b389e
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
@@ -38,6 +38,7 @@ import org.apache.spark.sql.ForeachWriter
38
import org.apache.spark.sql.execution.streaming._
39
import org.apache.spark.sql.functions.{count, window}
40
import org.apache.spark.sql.kafka010.KafkaSourceProvider._
41
+import org.apache.spark.sql.streaming.util.StreamManualClock
42
import org.apache.spark.sql.streaming.{ProcessingTime, StreamTest}
43
import org.apache.spark.sql.test.{SharedSQLContext, TestSparkSession}
44
import org.apache.spark.util.Utils
0 commit comments