У меня есть столбец в кадре данных, который является массивом [всегда одного элемента], который...
Допустим, у нас есть эти классы: case class MyList(list: Seq[Element]) case class Element(item:...
На моем сервере, который использует akka http, я хотел бы пометить определенные маршруты с помощью...
У меня есть данные CSV. Сначала я хочу преобразовать его в Json, а затем преобразовать в Pair RDD....
Я пытаюсь использовать библиотеку xtract , и я испытываю трудности при разборе xml. build.sbt:...
Я новичок в scala, только что начал с моим первым приложением scala. Я определил свой...
У меня есть текстовый файл в свободной форме (не XML), из которого я хотел бы проанализировать...
Я пытался удалить повторяющиеся слова из строки в scala. Я написал udf (код ниже), чтобы удалить...
Всегда получая значение Аккумулятора как 0. package com.fast.processing.data import org.apache
В классе GenericContainer существует метод waitingFor, который ожидает ответа от сервера с кодом...
Так что я пытаюсь найти и удалить все дубликаты из набора статей, прежде чем делать некоторые НЛП...
У меня есть искровое задание, которое случайным образом выбирает мои входные данные.Затем я создаю...
При запросе эластичного поиска из Spark выбирается только значение _id, но не любые значения....
Я читаю текстовый файл, и это файл фиксированной ширины, который мне нужно преобразовать в CSV.Моя...
Я читаю файл JSON в Scala Spark, используя val df = spark.read.json (properties.getProperty...
У меня есть 2 кадра данных, где df1 имеет столбец key1, а df2 имеет столбец key2. Здесь столбец...
Я хочу интегрировать потоковую передачу искры с kafka и запускать в intellij Моя kafka работает...
Я пытаюсь использовать https://github.com/testcontainers/testcontainers-scala, который присущ...
У меня следующий искровой фрейм: published data 2019-05-15T10:37:22+00:00...
У меня есть пять Hive таблиц, предположим, что имена A, B, C, D и E. Для каждой таблицы есть ключ...
Я работаю с Flink и пишу программу Scala, в которой я устанавливаю соединение с потоковым API...
Я пытаюсь заменить все виды комментариев (одиночные, встроенные и многострочные). Начальное...
У меня есть датафрейм, где некоторые строки содержат "" в начале и конце строки. Например:...
Я пытаюсь получить фрагмент Array как Seq, избегая копирования. Я могу использовать метод toSeq....
Я создаю rdd с wholeTextfiles.Я получаю filepath и filetext.Я хочу новый RDD с filepath и индексом...