Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
2.1.1
-
None
-
None
-
Spark 3.1.1
Description
In the open source doc link https://carbondata.apache.org/streaming-guide.html
import org.apache.spark.sql.streaming.
{ProcessingTime, StreamingQuery}--> this import statement can be replaced by --> import org.apache.spark.sql.streaming.Trigger.ProcessingTime
as the earlier import does not work
scala> import org.apache.spark.sql.streaming.ProcessingTime
<console>:23: error: object ProcessingTime is not a member of package org.apache.spark.sql.streaming
import org.apache.spark.sql.streaming.ProcessingTime
^
scala> import org.apache.spark.sql.streaming.Trigger.ProcessingTime
import org.apache.spark.sql.streaming.Trigger.ProcessingTime