В моем приложении у меня есть закрытый набор операций, которые возвращают соответствующий набор...
Допустим, у меня есть СДР в формате, подобном этому СДР [сотрудник], и примеры данных следующие: -...
Я пытаюсь прочитать файл CSV в Spark - используя API для чтения CSV. Я в настоящее время...
Я пишу наивную реализацию Kmeans в Spark для своей домашней работы: import breeze.linalg.{ Vector,...
В Spark у меня есть closest: org.apache.spark.rdd.RDD[(Int, (breeze.linalg.Vector[Double], Int))] =...
Следующий тест проходит в Scala 2.11 и 2.12, но не проходит, как показано для 2.10 class...
Я импортирую этот проект https://github.com/scalaz/scalaz в Intellij. Но у меня проблема с...
У меня есть следующий код Java: public static <T> T buildSAMLObject(final Class<T>...
Я пытаюсь вызвать конечную точку REST с помощью HttpGet и передать учетные данные пользователя. var...
Мы выполняем некоторое математическое моделирование данных из таблицы Cassandra с использованием...
Вот служба зависимостей: public class Service1 {} Scala-код, который использует его через...
У меня есть пример кода import org.apache.spark.sql.Row import scala.xml._ object reading_xml { def...
Проблема: initialize(...) метод вызывается несколько раз на recordProcessor, когда этот...
Просто предшественник, я пришел из Java и довольно новичок в Scala.По мере того, как я больше...
Я хотел бы построить скользящую среднюю на каждом ряду в окне. Допустим, -10 строк. НО, если...
Поскольку я хочу извлечь данные из двоичных файлов, я читаю файлы, используя val dataRDD = sc
У меня огромный список файлов: file.txt file.txt.tar.gz file.txt.tgz core123165 core123165.bak file
Вот небольшой набор функций, которые возвращают ReaderT: type FailFast[A] = Either[List[String], A]...
intellij-java-google-style.xml - это хороший способ отформатировать код Java для intelliJ IDEA, в...
Я должен заполнить первые нулевые значения непосредственным значением того же столбца в кадре...
Заранее спасибо! Я новичок в gcp и пытаюсь использовать Cloud SQL Postgres.У меня есть база данных,...
В Spark Streaming, используя Scala или Java, как получить поток, который всегда содержит самые...
Я пытаюсь вычислить статистику для таблицы Hive, используя контекст Spark SQL. Версия Spark: 1.6.3...
Получение исключения nullpointer в w.toSeq.toDS() в приведенном ниже коде. var w = new...
Я пытаюсь настроить автономный Mahout на локальном компьютере, где я могу запустить команду...