Я пытаюсь соединить кучу элементов в списке, чтобы создать конечный объект, аналогично созданию суммы объектов. Я пытаюсь использовать простую вариацию reduce , где для этого вы рассматриваете список пар, а не плоский список. Я хочу сделать что-то...

Я определяю функцию вспомогательной карты как отдельную функцию во вспомогательном объекте, и она не «видит» аккумулятор, определенный ранее в коде. Spark docs рекомендует хранить «удаленные» функции внутри объекта, но как мне заставить все это...

Вопрос. Является ли это допустимым способом проверки времени, необходимого для создания RDD? Я делаю две вещи здесь. Базовый подход заключается в том, что у нас есть M экземпляров того, что мы называем DropEvaluation, и N DropResults. Нам нужно...

Я пытаюсь использовать пользовательский аккумулятор в Apache Spark для накопления в наборе. Результат должен иметь тип Set[String]. Для этого я создал собственный аккумулятор: object SetAccumulatorParam extends AccumulatorParam[Set[String]] {...

нужна помощь с рубином! У меня есть цикл, когда я собираю данные о процессах PHP (PID, utimes). У меня есть два хеша. Первый «h1» выглядит так: "domain1" => { :utime => 0, :last_seen => 0, :process_count => 0, :process_count_avg...

Я использую аккумулятор в функции сгиба. Я хотел бы изменить значение аккумулятора. Моя функция выглядит примерно так: public Tuple2<String, Long> fold(Tuple2<String, Long> acc, eventClass event) { acc._1 = event.getUser();...

Я новичок в Haskell и пытаюсь реализовать функцию с аккумулятором, но не знаю, как правильно ее использовать. Вот функция, использующая список чисел и возвращающая тройку (Int, Int, Int) с длиной, суммой и суммой квадратов списка с помощью...