Что делает setTimeoutTimestamp() в mapGroupsWithState?
#scala #apache-spark #apache-spark-sql #spark-structured-streaming Вопрос: Может ли кто-нибудь помочь с работой setTimeoutTimestamp() в mapGroupsWithState() ? setTimeoutTimestamp() Удаляет ли состояние после того, как оно пересекает указанную продолжительность? Ответ №1: Согласно документам…