HeartSaVioR commented on code in PR #49099:
URL: https://github.com/apache/spark/pull/49099#discussion_r1874098128
##########
sql/api/src/main/scala/org/apache/spark/sql/streaming/StatefulProcessor.scala:
##########
@@ -20,16 +20,27 @@ package org.apache.spark.sql.streaming
import java.io.Serializable
import org.apache.spark.annotation.{Evolving, Experimental}
+import org.apache.spark.sql.api.EncoderImplicits
import org.apache.spark.sql.errors.ExecutionErrors
/**
* Represents the arbitrary stateful logic that needs to be provided by the
user to perform
* stateful manipulations on keyed streams.
+ *
+ * Users can also explicitly use `import implicits._` to access the
EncoderImplicits and use
+ * the state variable APIs relying on implicit encoders.
*/
@Experimental
@Evolving
private[sql] abstract class StatefulProcessor[K, I, O] extends Serializable {
+ // scalastyle:off
+ // Disable style checker so "implicits" object can start with lowercase i
+ object implicits extends EncoderImplicits {
Review Comment:
It's still valid, let's see {} is necessary.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
