Я пытаюсь вызвать functions.typedLit из библиотеки Spark в мой другой вопрос .И он запрашивает два...

В приведенном ниже фрагменте кода последнее утверждение не компилируется.Однако утверждение...

У меня есть один текстовый файл в следующем формате. id##name##subjects$$$ 1##a##science english$$$...

У меня есть файл sample.json, содержащий следующие данные JSON: {"query": "SELECT...

Учитывая список диапазонов дат, некоторые из которых перекрываются: val df = Seq( ("Mike"...

Я изучал Kafka Streams API и реализовал пример WordCountExample в Scala, а также в Java, но когда я...

У меня есть класс дел, определенный как ниже case class ChooseBoxData[T](index:T, text:String)...

import org.apache.spark._ import org.apache.spark.streaming._ import org.apache.spark.SparkConf...

После создания RDD из текстового файла мне нужно использовать .map для создания нового RDD типа...

Я недавно обнаружил случай, который не могу полностью понять при работе с Monix Task: Есть две...

Я был смущен этой ошибкой в ​​течение нескольких дней.Я чувствовал, что это может быть некоторые...

У меня есть файл конфигурации в папке ниже вычитать main scala resources application.conf и...

Я выполняю следующие операции: DataSet<Row> df1 = spark.read().format(AVRO_MODE).load(path1);...

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

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

У меня есть следующий JSON Json { "components": { "id": "application"...

как мне разобрать этот файл данных в spark / scala и взять каждые 9 строк как одну запись. Мне...

У меня есть сервер Java, создающий сообщение, похожее на это: @SerializedName("message")...

Как исправить эту ошибку в этом коде trait Processor00 { def process(oraOptionDfConfig:...

Я читаю JSON как: val df = spark.read.json(rdd) Я читаю сообщения из разных тем, поэтому не могу...

I am trying to implement following kind of code ' ValsProcessor { def...

Я получаю ошибку зависимости для моего SQLContext и sparksession в моей программе spark val...

Проблема: Мне нужно вызвать методы Objects, которые хранятся на карте, для данного ключа, как это...

У меня есть СДР 1000 элементов. Я хочу взять из него 100 элементов, а затем удалить эти 100 из...

Я написал ниже код для группировки и объединения столбцов val gmList = List("gc1"...