Flink: доступ с контролем состояния в RichAsyncFunction? - PullRequest
0 голосов
/ 25 июня 2019

В документации Flink для RichAsyncFunction указано:

API-интерфейсы, относящиеся к состоянию в RuntimeContext, пока не поддерживаются, поскольку ключ может изменяться при доступе к состояниям в рабочем потоке.

Что именно это значит?Какие звонки разрешены, а какие нет?Что произойдет, если будут сделаны вызовы к неподдерживаемому методу?

Документация для RuntimeContext здесь здесь .

1 Ответ

1 голос
/ 26 июня 2019

RichAsyncFunction предоставляет свой собственный подкласс RuntimeContext, который выбрасывает UnsupportedOperationException при попытке получить доступ к любому состоянию.

...