Я получаю данные откуда-то и вставляю их в cassandra ежедневно затем мне нужно извлечь данные из...

Допустим, у меня есть текстовый файл с такими данными, как ... my "sample data set"...

Я изучаю spark + scala с intelliJ, начав с небольшого фрагмента кода import org.apache.spark

Я пытаюсь сериализовать объект в JSON, используя scala-pickling 0.10.1 и Scala 2.11, но у меня...

Я пытаюсь объединить несколько таблиц улья, используя spark, где некоторые столбцы с одинаковыми...

Я пытаюсь заполнить кеш Scala для кофеина, который имеет формат Tuple to Boolean put((id,...

Я использую этот пример, предоставленный apache для потоковой передачи твитов. Однако я не могу...

я читал по книге "Скала для нетерпеливых" В главе 3 встречается этот код val a = Array(1, 7, 2, 9)...

******* ОБНОВЛЕНИЕ ******** Как предложено в комментариях, я исключил несущественную часть кода: Мои...

Я пытаюсь создать функцию udf, которая принимает значение столбца, при условии, что это значение...

Я работаю над Spark Scala, и существует требование сохранить Map[String, String] на диск, чтобы...

Я написал следующий код для подачи данных в алгоритм машинного обучения в Spark 2.3. Код ниже...

Я перефразирую вопрос из канала Цирце Гиттер здесь. Предположим, у меня есть иерархия запечатанных...

Я новичок в Scala, я пытаюсь запустить модель в Scala, но сталкиваюсь с некоторыми проблемами: Это...

Предположим, у меня есть несколько автоматически сгенерированных классов, таких как MyEnum1,...

Я использую оператор потока воздуха для запуска задания отправки искры. Работа искры принимает...

Я пытаюсь получить некоторые частые наборы предметов и правила связывания из Spark MLLib, используя...

Я столкнулся с проблемой при обновлении одного из значений столбца в Hbase с помощью Spark Scala....

У меня есть DStream[(Int,Int)], который выглядит так: (0,0), (1,0), (2,0), (3,0), (4,0), (5,0) и т....

Я пытаюсь запустить этот проект , после следующих инструкций, которые они предоставили: Установить...

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

У меня есть около четырех * .sql автономных дампов (около 20 ГБ каждый), которые мне нужно...

Я обнаружил, что Clojure имеет функцию clojure.core.reducers/fold. Также Scala имеет встроенную...

object IO { def getHtmlFromWebsiteViaHttp(link: String, apiKey: String = ""): String = {...

Я пытаюсь повторить этот код Python: cond_entropy_x = np.array([entropy(x[y == v]) for v in uy])...