Старый API-интерфейс структурированной потоковой передачи имеет MapWithStateDStream.stateSnapshots () для возврата снимка состояния для всех ключей. Я хотел бы знать, есть ли эквивалентная функция в API Spark Structured Streaming (Streaming DataSets)? Я ищу функцию API Java или Scala.