У меня есть тема, содержащая записи бухгалтерской книги, и я хочу получить к ним доступ в зависимости от временного окна.Например, дайте мне все записи за последний час.Или дайте мне записи с 1 до 2 часов утра и т. Д.
Ниже приведена топология потока.Он преобразует ключ / значение, а затем группируется по ключу, а затем обрабатывается в течение одного часа.После создания окна в течение одного часа будет несколько записей, и я хочу получить к ним доступ, указав время от времени.Здесь невозможно указать материализованное представление.Все примеры, которые я могу найти, будут дополнительно подсчитывать / агрегировать / сокращать до одной записи, а затем материализовать ее.Есть ли способ получить доступ к внутреннему оконному хранилищу состояний?Спасибо.
builder.stream("topic").transform() ..., keyValueStoreBuilder.name()).groupByKey().windowedBy(TimeWindows.of(360000));