Я столкнулся с очень странным поведением сортировки в scala (2.11.8 и 2.12.1) для Seq[(Long, Double)]. Я, наверное, неправильно понимаю что-то фундаментальное. Учитывая последовательность без каких-ли
Я читаю данные json из очереди Kafka с использованием искровой структурированной потоковой передачи, но мне нужно записать данные json в Elasticsearch. Однако я не могу получить sparkContext внутри Fo
Что такое идиоматический способ Akka выдавать SQL-заявления из приложения Akka? В частности, у меня есть конечная точка REST Akka Http, которая хочет выполнять команды SQL. Есть ли какая-то официальна
У меня есть небольшой набор данных твитов, и я хотел удалить имена пользователей из твитов. Я должен удалить все слова, начиная с @, но в последней операции map() следующего кода я получаю java.lang.S