Я пытаюсь создать CEP-код с использованием flink SQL, я хотел бы начать с этого. Было бы здорово,...

Мне нужно добавить «xml: lang» в качестве атрибута и «рубашку» в качестве значения в теге...

Я довольно новичок в мире Scala, и задача, над которой я сейчас работаю, - это перенести...

У меня есть датафрейм rating в формате ниже: id | percentile...

Кажется, что игра отсутствует в списке установки brew. Как мне установить его как отдельную команду

У меня есть фрейм данных val df = spark.sqlContext.createDataFrame(Seq( ("100"...

У меня есть несколько строк, хранящихся в исходной таблице (как определено как $schema.$sourceTable...

У меня есть такой набор данных: +----------+ | dt| +----------+ |2019-08-08| |2019-08-22|...

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

Я попытался определить максимальное значение из разных столбцов в одной строке в фрейме данных...

Я собираю пакет debian из проекта scala с помощью плагина sbt-native-packager. Пакет, созданный...

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

У меня есть список файлов gzip в папке S3, и я должен читать файлы, используя scala. Выполните...

Я использую приведенное ниже, чтобы создать фрейм данных (spark scala) с использованием внешней...

Я очень новичок в Scala, и при создании приложения я столкнулся с этим странным эффектом: Сначала...

Я работаю с набором данных, для которого новый разделитель строк установлен как ^M , и, поскольку...

Что такое сложность этих кодов? Я написал следующий код: let rec replicate (element, reps) = if...

Я создал функцию, которая принимает строку в качестве входных данных и дает строку в качестве...

В отличие от python, где пропущенное значение обрабатывается внутри алгоритмом XGBoost, при...

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

val dateFormat = DateUtils.parseDateStrictly ("12.03.2009 19:12", "ММ / дд / гггг ЧЧ: мм а") "12.03

Я хочу удалить последнюю строку из RDD с помощью функции .mapPartitionsWithIndex. Я пробовал ниже...

Я пытаюсь записать искровой датафрейм на кассандру с уровнем согласованности "EACH_QUORUM". Мой код...

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

Я попытался объединить два кадра данных относительно столбца, которые не имеют точно одинаковые...