Что делает setTimeoutTimestamp() в mapGroupsWithState?

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

Продолжить чтениеЧто делает setTimeoutTimestamp() в mapGroupsWithState?