AggregatorMax Класс

Определяет агрегатор, который возвращает максимальное значение на основе ключей объединения.

Наследование

Aggregator

AggregatorMax

Конструктор

AggregatorMax()

Комментарии

Экземпляры агрегаторов обычно не создаются напрямую. Вместо этого указывается тип агрегатора при использовании средства обогащения, например, объекта HolidayEnricher.

Метод process_public_dataset(env, _public_dataset, cols, join_keys) возвращает максимальное значение.

Методы

get_log_property	Возвращает кортеж свойств журнала; значение None, если свойство отсутствует.
process_public_dataset	Возвращает максимальное значение на основе ключей объединения.

get_log_property

Возвращает кортеж свойств журнала; значение None, если свойство отсутствует.

get_log_property()

process_public_dataset

Возвращает максимальное значение на основе ключей объединения.

process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)

Параметры

Имя	Описание
env Обязательно	RuntimeEnv Среда выполнения.
_public_dataset Обязательно	PublicData Входной общедоступный набор данных.
cols Обязательно	list Список имен столбцов для извлечения.
join_keys Обязательно	list Список пар ключей объединения.

Возвращаемое значение

Тип	Описание
	Агрегированный общедоступный набор данных.