Я новичок в Scala, поэтому, пожалуйста, несите в моем коде какие-либо помехи.Я пытаюсь переделать...
В кадре данных для каждого столбца III я назначаю фиксированную ширину и сохраняю обратно в HDFS,...
Мне нужно перенести в Spark 2.1 приложение, написанное на Scala 2.10.4 с использованием Spark 1.6....
Я пытаюсь загрузить файл GeoJson, используя библиотеку Magellan.Но сталкиваются с ошибками.Мой код:...
List1 = (" data center best practice design","essentials advantage"...
У меня есть источник потока, и я сначала пытаюсь получить модель K-средних кластеризации.Позже я...
У меня есть вывод снизу scala code val aryDF = Seq((("g3,g4"),Array(("D2,D3...
Я написал "import sqlContext.implicits._";Однако это все еще не работает.Это верно в искровой...
У меня есть List[Map[String, Any], и я хочу вернуть карту, которая имеет определенное значение для...
Ошибка компиляции: [ошибка] найдена: ((Double, Double)) => scala.concurrent.Future [(Double,...
Ищет, нашел ли кто-нибудь способ выполнения upserts (добавление / обновление / частичное вставление...
Что такое идиоматический способ FP: скажем, у меня есть это trait Name object Name{ def apply(name:...
Я пытаюсь создать функцию spark, которая рекурсивно перезаписывает столбцы ArrayType: import org
Я запускаю приложение, которое требует кодирования PDF в Base64 в Scala (AKKA).Эта ошибка...
У меня есть следующий код: object foo{ def splitSeq[Int](in: List[Int], out: List[(Int,Int)] =...
Как мне получить функцию более высокого порядка в Scala для правильного принятия предиката...
Можно ли заставить полуавтоматические декодеры учитывать значения по умолчанию для полей класса...
У меня есть Spark-код в Scala, например: scala> myfile.filter(!_
У меня есть список, содержащий случайное количество элементов Список Emp 101 [a, b, c, d, e] 102 [q...
Я установил xgboost на свою машину, и теперь я пытаюсь запустить простой проект scala на spark,...
Я группирую свой набор данных, как показано ниже import org.apache.spark.sql.functions._ DS
Я создаю актера, который должен запланировать отправку сообщения самому себе. Я заметил, что есть...
У меня есть потоковый фрейм данных Spark с временным окном в час, которое срабатывает каждую минуту
Оптимизация кода У меня есть приложение flink, которое считывает данные с URL / порта, выполняет их...
Мне нужно количество строк в тексте JSON, где A.adList.optionalField = null JSON выглядит так: {...