У меня есть код для анализа файла журнала, используя map transformatio n. Затем RDD был...

Я должен сделать простое удаление "." из строк, прежде чем делать подсчет слов. Он работает...

Мне нужно найти наиболее распространенное «необычное» слово в текстовом файле. У меня есть список...

Я хочу загрузить определенный список файлов в Spark. Я сделал UDF, который фильтрует список файлов,...

У меня есть датафрейм с двумя уровнями вложенных полей root |-- request: struct (nullable = true) |...

Я нашел программу JsonToCSV.scala в репозитории GitHub https://github.com/salamonpavel/jsonToCsv, и...

У меня есть DataFrame df со следующей структурой: root |-- author: array (nullable = true) | |--...

Я пытаюсь перенести одно из моих приложений из RDD в набор данных. Бизнес-логика сильно зависит от...

Я написал код выше, чтобы определить тип String на основе некоторых правил. def dataType...

Я новичок в скале. Я пытаюсь что-то на соответствие шаблону регулярного выражения. Я следую примеру...

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

Позвольте мне объяснить это на примере. Начиная со следующего кадра данных val df = Seq((1,...

Диаграмма иерархии наследования Scala: Диаграмма выше из книги Scala для нетерпеливых показывает,...

У меня есть сервер приложений Proxy Play (сервер A) перед другим сервером (сервер B). Когда на этом...

Я использую jayway JsonPath. Предположим, у меня Json вот так: JSONObject: { "balance":...

Должен ли я использовать постоянство или изменить операцию groupBy? def joinTests(measurements:...

У меня есть эта аннотация, которую я написал на Java, поскольку Scala не позволяет определять...

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

Насколько я знаю, поле в Java и Scala, помеченное как Volatile, обеспечивает взаимосвязь...

Возможно ли это в spark-scala? Я использую свечи 2.2 val...

Когда я анализирую XML-файл на AWS S3, я получаю исключение. Когда я анализирую тот же файл на моем...

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

Я почти уверен, что не существует простого способа сделать это, но вот мой вариант использования: У...

У меня есть класс дела: case class ProfileUrl ( profileId : Long, socialUrl : String ) implicit val...

Я работаю над проектом, который требует зависимости geotools . Прежде чем я получил следующую...