Поток событий Akka Persistence Query и CQRS

Я пытаюсь реализовать сторону чтения в моей архитектуре ES-CQRS. Допустим, у меня есть постоянный актер, как это:

Как перебрать scala wrappedArray? (Искра)

Я выполняю следующие операции:

как преобразовать строку JSON в датафрейм на искре

Я хочу преобразовать строковую переменную ниже в фрейм данных на спарк.

Scala инициализация поведения

Не реализована реализация для play.api.db.slick.DatabaseConfigProvider

Неявное преобразование между коллекциями Java и Scala с использованием JavaConversions

Правильный способ остановить потоки Акка при условии

Spark SQL не работает, потому что «Пул констант превысил предел JVM, равный 0xFFFF»

Я запускаю этот код на EMR 4.6.0 + Spark 1.6.1:

Java Spring как клиент для REST HTTP-вызова на основе Akka

Как заполнить java.util.HashMap на лету из кода Scala?

Я занимаюсь модульным тестированием Java-кода из ScalaTest и хотел бы заполнить java.util.HashMap в том же заявлении, в котором он объявлен. Возможно ли сдел...