У меня есть RDD с формой long, int, string, Array[Double], которую мне нужно преобразовать в...

Я работаю с dstream из kafka, который выглядит как запись ниже. Я изо всех сил пытался получить...

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

Входные данные: key,date,value 10,20180701,a10 11,20180702,a11 12,20180702,a12 13,20180702,a13 14...

У меня есть один DataFrame (d1) с (index, features) и второй (d2) с теми же столбцами. features...

Я хотел бы иметь функцию, которая открывает файл sequenceFile и предоставляет путь к файлу,...

От: https://github.com/spotify/scio/wiki/Scio-data-guideline "Предпочитайте комбинировать /...

Я новичок в области IntelliJ / SBT, поэтому я могу упустить очевидные вещи.Однако после долгих...

У меня есть класс в Scala, который выглядит так: class A { private val b = new B() def...

Поскольку экстракторы не могут принимать пользовательские параметры (как было сказано в...

У меня есть DataFrame, подобный этому: id val1 val2 ------------ 1 v11 v12 2 v21 v22 3 v31 v32 4...

Я создал фрейм данных из файла CSV. Он имеет 10 столбцов, две из которых - актриса и название...

У меня есть SparkSQL DataFrame, подобный этому: name gender age isActive points...

Скажем, у меня есть Spark SQL DataFrame, например: name gender grade ----------------- Joe M 3 Sue...

Я работаю со значениями данных, поступающими от датчиков. Эти данные чрезвычайно велики. Если я...

Я ищу коллекцию с наиболее эффективной параллельной операцией добавления элемента. Scala или Java...

Мне нужно saveAsSequenceFile мой объект класса Java (по какой-то причине я не могу исправить сам...

У меня есть список общедоступных ресурсов внутри папки "src / main / resources", который выглядит...

Я одобряю этот пример машинного обучения Apache , чтобы создать систему рекомендаций для наших...

Я хочу отобразить две конечные точки API REST в интерфейсе Swagger: / cart и /post. Когда я...

У меня есть раздел RDD в кластере, и я хочу сделать reduceByKey для каждого раздела отдельно.Я не...

Я пытался исследовать январь с помощью Scala. Итак, для заданных вершин v1 и v2 я хотел бы выяснить...

Я новичок в scala и несколько часов бьюсь над итерацией этого массива WrappedArray в массиве и...

Как сохранить Theta Sketch (Yahoo) в таблице SnappyData вместо записи в файл?Потому что я создаю...

Я пытаюсь обновить основную таблицу (HBASE) только для 1 столбца, но происходит то, что все...