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

Я пытаюсь прочитать файл Excel, расположенный в HDFS. Я использую банку Spark Excel,...

В настоящее время я делаю функцию, которая возвращает объект. Но если я нахожу что-то недопустимое...

Я пишу программу на Scala и хочу найти корни уравнения: 2*x^3 + x*(1-2*l + 2*H)-m = 0, где l, H и m...

Мне нужно прочитать данные из двух разных кластеров Elastic Search. один для журналов и один для...

Входной фрейм данных val ds = Seq((1,"play Framwork"), (2,"Spark framework"),...

У меня есть следующий код: - val kafkaStream = KafkaUtils.createStream[String, String,...

Я пытаюсь использовать структурированную потоковую передачу в искре, так как она хорошо подходит...

Мне нужно получить переменные-члены / параметры класса case в java. Я попытался использовать API...

У меня есть ввод spark-dataframe с именем df как, +---------------+----+----+----+...

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

Я пытаюсь открыть файл grib2 с помощью NetcdfDataset.openDataset () val path= getClass

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

Я работаю с фреймом данных со следующей схемой: root |-- Id: integer (nullable = true) |--...

Если у меня есть Class Box[+T] { num: Int, t: T } И я хочу создать метод, который добавляет два...

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

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

У меня была работа с потоковым воспроизведением, которая анализировала потоковую запись kafka json...

Я создал СДР ключа / значений следующим образом: RDD[(String, Int)]: rdd.map(row => row.split(1)...

У меня есть работа с потоковым воспроизведением, и у меня возник вопрос о преобразовании типов....

У меня есть работа с потоковым воспроизведением, коды там внизу: val filterActions = userActions

Я читаю строку длиной более 100 Кбайт и разделяю столбцы по ширине. У меня есть столбцы размером...

sample code:- val list=Seq("symbol").map(column=>col(column)) val windowedCount =...

Если у меня есть список смежности, представленный в Scala следующим образом: val l = List( List((1,...

Я пытаюсь обернуть определенную функцию Scala в преобразование с использованием конвейера import...