Я пытаюсь загрузить удаленную таблицу базы данных Oracle в оболочку Apache Spark. Вот так я...

class MyTable(tag: Tag) extends Table[MyEntity](tag, "1970Table") { def id =...

У меня есть метод, который принимает год (int) в качестве параметра. В зависимости от года, мне...

Я пытаюсь проанализировать набор данных размером 500 МБ в Databricks. Эти данные хранятся в файле...

Я пытаюсь преобразовать выражение в Scala, которое сохраняется в базе данных как String, обратно в...

База на Документация Akka : Если вы хотите убедиться, что ваши реквизиты являются сериализуемыми,...

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

У меня есть код структурированного потокового скала, написанный для запуска в пакетном режиме.Я...

Я работаю над проблемой, когда хочу отобразить ближайшую дату / время из текущей даты в Scala. У...

У меня есть много индексов Elasticsearch со многими полями, которые я хочу использовать в Spark....

Я выполняю внутреннее соединение, скажем, с 8 кадрами данных, все из одного и того же родителя

В игре Connect4: мы начинаем с пустой сетки два игрока кладут фигуры х и о на сетку выигрывает...

Мне нужно очистить экран консоли в Scala Я пробовал стандартный экран ANSI Clear, который был...

У меня есть проект по анализу больших данных.Я использовал Spark для этого и писал с использованием...

Я работаю над Databricks, платформой обработки данных на основе Spark с HDFS-подобной файловой...

Я нахожу средние значения с помощью функций groupBy и mean, например: x.groupBy("Col1",...

Я работаю с инструментом, написанным на scala и python, который называется web2text .Мой набор...

Я пишу приложение Scala, используя стороннюю библиотеку. При выполнении итерации по коллекции из...

У меня есть требование, при котором я должен получать сообщения из 3 тем kafka в виде потоковых...

Spark версия 1.6.0 Я использую функцию соединения между двумя фреймами данных, которые имеют 100...

Я занимался некоторыми проблемами Эйлера в Scala, когда нашел очень элегантное решение проблемы # 2

использование блока if в scala для распределенных вычислений наименее рекомендуется. У меня есть...

Я пытаюсь выучить искру с помощью электронного курса Фрэнка Кейна «Apache Spark with scala».Я...

Скажем, у меня есть 4 блока инструкций искры, представленных как Dataframe A, B, C и D. Dataframe...

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