Попытка перехватить и записать строковое значение после замены содержимого, полученного из...
Я пишу искровое приложение, которое берет данные транзакций из Hive и соединяет их с данными о...
Мне нужно решить проблему.У меня есть производитель kafka, который производит сообщения (xmls) на...
Я пытаюсь прочитать текстовый файл в Примеры Spark-mllib (Word2VecExample) и создать в нем векторы...
Я новичок в Scala, и у меня есть два кода: private val uploadImageTypeValidator =...
Я могу создавать дельта-таблицы блоков данных, используя scala, и выполнять над ними операции...
Я пытаюсь преобразовать набор данных в итератор в Java-программе, используя метод toLocalIterator....
Я новичок в Скале. Написание моего первого заявления. Я определил свой файл прото с полями email_id...
У меня есть этот список: List("Black","Black","Green"...
Я новичок в использовании Python, так что простите, если вопрос звучит просто. Если у меня есть...
Впервые в Scala. Я создал функцию подстроки в scala, которая требует "pos" и "len", я хочу, чтобы...
Что-то в данный момент кажется неправильным с моим проектом веб-приложения и его внутренними...
У меня есть список интервалов, которые я хотел бы объединить при наложении. пример: List((1,1),(2...
Я работаю над сервисом потокового воспроизведения, который читает транзакции из каталога hdfs и...
У меня есть CSV-файл, как показано ниже В нем 6 строк с верхней строкой в качестве заголовка, в...
Я пытаюсь отправить список [KeyValue] в тему в приложении Kafka Streams.Но поток ожидает...
Я использую Slick 3.3.0 для создания приложения и имею следующий простой (я полагаю) вариант...
У меня есть следующий фрейм данных val count :Dataframe = spark.sql("select 1,$database_name...
У меня есть работа spark, где я читаю данные из нескольких файлов hadoop и записываю их в таблицу...
Считайте, что у меня есть следующие таблицы: A, B и AB. Таблицы AB - это таблица связей между A и B
Я пытаюсь получить размер папки для некоторых папок S3 с scala из командной строки EMR. У меня есть...
У меня есть искра DataFrame, подобная этой:...
В Scala есть специальный синтаксис, позволяющий выполнять какую-либо функцию "присваивания" или...
Я пытаюсь запустить шаг чистой сборки с помощью sbt в файл jenkinsfile.Я использую следующий шаг:...
Я хочу, чтобы класс дел расширял черту Вот мои требования: Мне нужно использовать класс дел для...