#apache-flink #flink-streaming
Вопрос:
Я использую функцию процесса с ключом для использования бэкенда состояния RocksDB. Я хочу удерживать два разных состояния для одного и того же ключа;
- Состояние 1 тип: Значение[Строка]
- Состояние 2 тип: Состояние карты[Строка, Длинная]
В этом случае мне нужно создать два дескриптора состояний в одной и той же функции процесса с ключом. Возможно ли это во флинке?
Ответ №1:
Да, у вас может быть столько дескрипторов состояний в ключевой функции процесса, сколько вы хотите. У каждого должно быть уникальное имя (область действия оператора/функции).
См. Решение для тренировочного упражнения «Поездки и тарифы» для примера.