在文档中,它说结构化流中的诸如 mapGroupsWithState 之类的状态操作仅在 Scala 和 Java 中受支持,但我确实需要 Python 中的状态功能。我应该怎么办?
spark-streaming
spark-streaming ×1