Как вручную вмешаться в состояние KSQL?
Я использовал ksql для вычисления некоторых показателей в реальном времени на основе живых событий. Теперь я хотел добавить новую метрику и хочу использовать ее прямо сейчас.
Как рассчитать новое состояние на основе существующего состояния (оно не существует в исходном ksql, но, возможно, его можно рассчитать в автономном режиме)?
Вопрос в том, можно ли вручную вмешаться в состояние KSQL?
Новая метрика похожа на то, сколько раз пользователь совершал вход в систему или сколько раз пользователь покупал кубики LEGO за последние 90 дней и т. Д.