У меня есть приложение Scala с build.gradle (используя gradleVersion 4.4.1).Я использую JUnit...

Допустим, у меня есть набор данных [MyData], в котором MyData определяется как: case class...

Моя проблема довольно проста, действительно. Я написал класс обработчика Scala, который возвращает...

Я использую spark и scala на jdk1.8. Я новичок в Scala. Я читаю текстовый файл (pat1.txt), который...

У меня есть дата, и я хочу добавить и вычесть 10 дней к ней.Start_date и end_date являются...

У меня есть фрагмент кода, который выглядит следующим образом abstract class ClassA(var data:...

Я пытаюсь отфильтровать список файлов по двум условиям.И следующий код работает import java.io.File...

Я пытаюсь загрузить массив данных размером ~ 67 ГБ (6 000 000 функций на 2300 строк) в компьютер...

Я написал код для подсчета слов, но когда я попытался запустить его из CMD в Windows, используя...

У меня есть значения в фрейме данных, и я создал структуру таблицы в Teradata.Мое требование -...

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

У меня есть эти 2 функции: 1) protected def withBagAsync(body: Bag => Future[Result]):...

Я новичок в Spark и Scala. Я создал DataFrame из CSV в Spark.В сгенерированном DataFrame есть...

Мне нужны собственные метрики, которые определяются свойствами бизнес-объектов.Например, quadkeys,...

У меня есть такой фрейм данных: +-----------------+------------------+-----------+--------+---+ |...

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

У меня есть очень специфический (и странный) текстовый файл, который не является XML-файлом, но...

У меня есть две большие таблицы.Я присоединяюсь к этим двум таблицам в Spark sql, как будто select...

У меня есть 2 формата JSON (example_json1, example_json2) и простой класс Address для анализа JSON...

Я хочу взять два столбца из двух разных таблиц и объединить их в одну таблицу, но без использования...

Это структура кода: case class Demo(path:String){ private val df: DataFrame = read() var a = df

Я все еще очень новичок в Spark и Scala, но очень хорошо знаком с Java.У меня есть java jar, в...

Я упаковал свое приложение в jar-файл, однако, когда я пытаюсь его выполнить, приложение...

Мне нужно отправить данные из Кассандры в Elasticsearch.Загружен фрейм данных из cassandra, но...

Я пытаюсь проанализировать Dataset, который имеет следующий формат: country-name date population...