anishshri-db commented on code in PR #53355:
URL: https://github.com/apache/spark/pull/53355#discussion_r2594352926
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/operators/stateful/statefulOperators.scala:
##########
@@ -1561,4 +1574,14 @@ object StatefulOperatorsUtils {
TRANSFORM_WITH_STATE_IN_PYSPARK_EXEC_OP_NAME
)
val SYMMETRIC_HASH_JOIN_EXEC_OP_NAME = "symmetricHashJoin"
+ val STATE_STORE_SAVE_EXEC_OP_NAME = "stateStoreSave"
+ val DEDUPLICATE_EXEC_OP_NAME = "dedupe"
+ val DEDUPLICATE_WITHIN_WATERMARK_EXEC_OP_NAME = "dedupeWithinWatermark"
+ val SESSION_WINDOW_STATE_STORE_SAVE_EXEC_OP_NAME =
"sessionWindowStateStoreSaveExec"
+ val FLAT_MAP_GROUPS_WITH_STATE_EXEC_OP_NAME = "flatMapGroupsWithState"
+ val FLAT_MAP_GROUPS_IN_PANDAS_WITH_STATE_EXEC_OP_NAME =
"applyInPandasWithState"
Review Comment:
nit: should we rename as `APPLY_IN_PANDAS_WITH_STATE_EXEC` ?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
