Я пытаюсь использовать scala-cass для чтения из cassandra и преобразования набора результатов в класс case с использованием resultSet.as[CaseClass] . Это прекрасно работает при выполнении следующего. import com.weather.scalacass.syntax._...

Я хочу создать потребителя очереди сообщений, который на данный момент будет иметь только одну реализацию для Kafka, но позже он может иметь и другие реализации. trait MessagingQueueConsumer { def consume[B <:...

Я пытаюсь создать несколько простых пользовательских агрегатных операторов в Spark, используя Scala. Я создал простую иерархию операторов со следующим суперклассом: sealed abstract class Aggregator(val name: String) { type Key = Row //...