Я получаю поток событий, который необходимо дополнить некоторыми дополнительными деталями. Эти данные необходимо получить из Cassandra DB и применить к входящему событию. Для этого я использую DataStream API Flink. Любой рабочий пример с Scala будет действительно большим подспорьем.