У меня есть датафрейм с 5 столбцами.Теперь мне нужно получить максимум минут для каждой категории...
Scala 2.12 здесь. Я пытаюсь использовать Lift-JSON для десериализации некоторого JSON в объект...
У меня есть набор данных с датой, учетной записью и значением. Я хочу преобразовать набор данных в...
Я хочу преобразовать этот код Scala в код Pyspark. Код Scala: Row={ val columnArray = new...
У меня есть пример схемы Avro: { "type": "record", "name":...
У меня есть фрейм данных +-----+----+----------+------------+----------+------------+ |empId| lId|...
Я унаследовал большой проект Scala со многими файлами / классами. Чтобы внести изменения и...
У меня есть папка с множеством паркетных файлов, имена которых следующие:...
У меня есть искровой проект, основанный на scala и maven, я использовал плагин...
У меня есть фрейм данных Spark (1.4), где данные в столбце похожи на "1-2-3-4-5-6-7-8-9-10-11-12".Я...
ОБНОВЛЕНО: Метод возвращает тип ЛЮБОЙ, а не тип Future [строка].Требовать возврата типа String. Я...
Следующий фрагмент кода занимает много времени на 4 ГБ необработанных данных в кластере: df
У меня есть большой граф (несколько миллионов вершин и ребер).Я хочу удалить все вершины (и ребра),...
Можно иметь массив разделов Spark DataFrame следующим образом: > df.rdd.partitions Есть ли...
Я новичок в Spark & Scala и получил исключение после вызова saveAsTextFile ().Надеюсь, что кто-то...
Почему следующий код имеет ошибку компиляции в операторе возврата, def getData(queries:...
Для входа Dataframe намерение состоит в том, чтобы генерировать только половину само декартового...
Я пытаюсь использовать безопасные классы BigQuery. Я также установил intellij scio плагин . Но я...
У меня есть потребность, где я хочу при желании фильтровать данные. def test(df: DataFrame,...
У меня есть записи, подобные приведенным ниже. Разделенные пробелами / разделенные: 2015-07-22 5555...
скажем, например, это JSON, как показано ниже. Я на самом деле взял это с сайта Amazon, но я думаю,...
Как я могу предотвратить использование определенного неявного в моем коде scala? Например, недавно...
Я написал следующий очень простой тест: import scala.collection.immutable.HashSet class Test { def...
У меня есть тип Scala: Array[java.lang.Object] Пытался повторить его: for (el <- arrayTest) {...
Как можно развернуть массив внутри фрейма данных искры, чтобы результирующий фрейм данных содержал...