В настоящее время я создаю агрегатор необработанных данных журнала, используя Spark Structured...

Я перенес свой проект в Play 2.6.18. Версия Scala - 2.12.6. Когда я запускаю sbt compile или sbt...

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

Я пишу приложение Spark, используя Scala. У меня есть следующие два RDD: (a, 1, some_values1) (b, 1...

Я использую State-Monad из библиотеки кошек, чтобы позаботиться о состоянии карточной игры, которую...

Учитывая набор данных, как вы видите в приведенном ниже коде (df), я должен иметь возможность...

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

Я работаю над файлами PST, я работал над созданием специального устройства для чтения записей для...

Привет, я новичок в Spark и Kafka, я пишу пример кода для использования сообщений из темы Kafka с...

Я хочу сравнивать Prev.data с текущими данными по месяцам.У меня есть данные, как показано ниже....

У меня есть класс, где мне нужен метод apply[T], где T может быть только Foo или Bar. Кроме того,...

Учитывая Spark DataFrame со столбцом идентификаторов и столбцом нормализованных векторов объектов:...

Я пытаюсь испачкать руки с помощью Scala, где я играю с scala.collection.immutable.StringOps на...

Как видно из заголовка, у меня есть последовательность векторов (в столбце DataFrame, но ее можно...

Следующий код иллюстрирует общий шаблон маршрутизации Akka http: lazy val routes:Route {......

Я пытаюсь сопоставить группу, в которой есть только «Джек» в предложениях ниже. Я хотел бы сделать...

Я пытаюсь разобрать читаемый PDF-файл, находящийся в hdfs. Я импортировал требуемые банки Проблема,...

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

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

Я пытаюсь прочитать файл json, чтобы вычислить некоторые метрики в scala.Мне удалось прочитать файл...

У меня есть RDD[(BreezeMatrix[Double], Array[Int])], и я хочу удалить столбцы Matrix, которые...

отсутствует или обнаружена неверная зависимость при загрузке файла класса 'KafkaUtils.class. Не...

У меня есть структура данных, скажем MinHeap. У него есть такие методы, как peek (), removeElement...

У меня есть набор данных со столбцом stringType, который содержит нули. Я хотел изменить каждую...

Недавно я разработал приложение Spark Streaming с использованием Scala и Spark. В этом приложении я...