Как мне обработать |, который также является разделителем в моих данных, Вот примерное значение...
Я работаю с набранным Akka, и я не могу проверить в официальной документации (https://doc.akka
Я использую фреймворк Scala и у меня есть простой шаблон: @defining({ Map("a" -> 1,...
Давайте предположим, что у меня есть RDD с элементами типа case class Foo(name: String, nums:...
Как показано в Confluent docs при написании приложений PAPI , вы должны закрыть хранилища, которые...
Я пытаюсь добавить столбец в таблицу Hive, если в исходных данных появились новые столбцы.Все...
Привет. Я пытаюсь отфильтровать эти триплеты по их свойствам и распечатать их, но у меня возникли...
Я пытался использовать метод с именем random со следующей подписью: def random[T: WeakTypeTag:...
У меня есть данные, разделенные табуляцией: 1 abc {'sci': 141, 'math': 274,...
Я использую Spray-JSON в SCALA. SPRAY-Github Я хочу исключить (игнорировать) некоторые поля из...
Мне нужно сравнить файлы CSV, а затем удалить все дублирующиеся строки.Итак, мое состояние таково,...
Я пытаюсь получить данные из улья и вставить их в Cassandra с помощью Spark. Очень удивительно, что...
Фон Значение forExpression (ниже) возвращает монаду StateT, которая принимает в качестве параметра...
У меня есть следующий код Scala: import collection.JavaConverters._ val threads : Seq[Thread] =...
Конфигурация программного обеспечения: Hadoop distribution:Amazon 2.8.3 Applications:Hive 2.3.2,...
Я хочу прочитать train.csv в спарк, но похоже, что спарк как-то неправильно читает файл.Я прочитал...
Я пытаюсь отредактировать конфигурацию размера блока hadoop через оболочку spark, чтобы...
Мой код: abstract class List[T] { def reduceRight(op: (T, T) => T): Either[String, T] = this...
У меня возникли проблемы с зависимыми от пути типами и ковариантными параметрами.Мне нужно создать...
В настоящее время я добавляю столбец с меткой времени к существующему фрейму данных в моем скрипте...
Я пытался найти способ повторной рассылки функций в различных событиях на основе временных отметок...
У меня есть следующий код в Scala: val FilteredPSPDF = PSPDF.select("accountname"...
Следующий код выдает ошибку времени выполнения, как показано ниже.Может быть причина, почему...
Итак, у меня проблема с Kafka Sinks в Spark Streaming при отправке JSON для нескольких тем и...
Из метода scala я хочу вернуть переменное число столбцов Spark, например: def getColumns() :...