Возврат нескольких массивов из определяемой пользователем статистической функции (UDAF) в Apache Spark SQL

Я пытаюсь создать пользовательскую агрегатную функцию (UDAF) в Java, используя Apache Spark SQL, который возвращает несколько массивов по завершении. Я искал...

Переполнение стека при обработке нескольких столбцов с помощью UDF

у меня есть

Применение функции к столбцу Spark Dataframe

Исходя из R, я привык легко выполнять операции над столбцами. Есть ли простой способ взять эту функцию, которую я написал в Scala

Apache Spark - присваивает результат UDF нескольким столбцам данных

Как передать постоянное значение в Python UDF?

Определение UDF, который принимает массив объектов в Spark DataFrame?

При работе с DataFrames Spark пользовательские функции (UDF) необходимы для отображения данных в столбцах. UDF требуют, чтобы типы аргументов были указаны яв...

лучше с

дал

).

который может быть использован, как показано ниже

отаю над UDAF, который возвращает массив элементов.Входными данными для каждого обновления является кортеж индекса и значения.UDAF суммирует все значения по ...

).

тоящее время я работаю со Spark 2.1 и имею основной скрипт, который вызывает вспомогательный модуль, который содержит все мои методы преобразования. Другими ...