Я настраиваю Apache Flink, связанный с брокером Kafka.
Я получил следующие сообщения в случайном порядке:
- сообщение (отметка времени = [..], индекс = 1, someData = [..])
- сообщение (отметка времени = [..], индекс = 2, someData = [..])
- сообщение (отметка времени = [..], индекс = 3, someData = [..])
- сообщение (отметка времени = [..], индекс = 2, someData = [..])
- сообщение (отметка времени = [..], индекс = 3, someData = [..])
- сообщение (отметка времени = [..], индекс = 1, someData = [..])
В моих записях, исходящих от Кафки, есть поле index.
В моем приложении мне нужно вычислить последние две из этих записей с одинаковым идентификатором, а затем немедленно отправить ответ.
Например, эти два:
- сообщение (отметка времени = [..], индекс = 1, someData = [..])
- сообщение (отметка времени = [..], индекс = 1, someData = [..])
Как лучше всего хранить и вычислять две последние записи с одним и тем же индексным полем? Не могли бы вы дать мне несколько советов?
