Предположим, я хочу создать тип NonZero, чтобы моя целочисленная функция деления была общей: def...
Я обрабатываю данные, где некоторые записи могут быть повреждены.Поэтому я решил исследовать данные...
Предположим, у меня есть ADT в Scala: sealed trait Base case class Foo(i: Int) extends Base case...
Библиотека grpc-java является хорошим примером библиотеки, которая использует общий шаблон...
Я использую функцию assert в scala для сравнения XML-файлов.Моя проблема заключается в том, что я...
Наше приложение работает в кластере с 3 узлами.Для распределения работы по кластеру мы обычно...
У меня есть json {"status":"ok","totalResults":9...
У меня есть список функций агрегирования, псевдонимов и других, таких как конфигурация JSON,...
Просто я хочу преобразовать мультикарту следующим образом: val input = Map("rownum"->...
Мой ввод HBase таблица.сначала я загружаю данные и функция withCatalog вернет Dataframe. def...
Я работаю с фреймом данных искры, где он содержит все значения меток времени из Column...
В приведенном ниже кадре данных искры есть start_t и end_t в формате unix, но в нем...
Имейте некоторый набор данных сотрудника.в том, что мне нужно разделить зарплату сотрудника на...
Я бы хотел прагматично взаимодействовать с ульем из окон, ниже я написал код: package com.vz.vbap
Я пытался добавить настраиваемый десериализатор в класс дел для объекта LocalDateTime, однако он...
В кадре данных df у меня есть столбец datetime, который содержит значения меток времени.Проблема в...
Мне нужно создать PairRDD (draft_ids), где key - это идентификатор проекта, а value - это все поля,...
Я пытаюсь присоединиться к DataFrame (dfA) последовательно в одном и том же DataFrame.Допустим, в...
У меня есть вложенная структура каталогов, которая выглядит следующим образом: folder │ folder ├──...
Я пытаюсь создать многоуровневый Validator объект, который является достаточно общим.Идея в том,...
Я пытаюсь объединить Edge RDD с RDD (Long, Long, String).Мой край RDD выглядит следующим образом:...
У меня есть следующая строка, которая является параметром пути в методе sparkContext.textFile s3:...
Я следую примеру в https://typelevel.org/cats/datatypes/validated.html, но с изюминкой: тип...
Я новичок в scala и scala-api spark, и я недавно попробовал scala-api spark на своем компьютере,...
Я пытаюсь вычислить проводимость графика, используя GraphX.Чтобы добиться этого, мне нужно...