convert_eenheden
Belangrijk
Een gedeelte van of alle functionaliteit is beschikbaar als onderdeel van een preview-release. De inhoud en functionaliteit zijn aan verandering onderhevig.
Converteer maateenheden voor opgegeven kolommen in het geaggregeerde DataFrame naar doeleenheden.
Parameters:
- df (
DataFrame): Invoer DataFrame met waarden om te converteren. - uom_id_column (
str): Kolomnaam die de meeteenheid-ID weergeeft. - value_columns (
list): Lijst met kolommen waarop de conversie moet worden toegepast. - target_units (
list): Lijst met namen van doeleenheden waarnaar moet worden geconverteerd.
Retourneren:
DataFrame: DataFrame met geconverteerde eenheden.
Verhogingen:
ValueError: Als de conversiefactor voor sommige eenheden niet wordt gevonden.
Voorbeeldgebruik:
water_aggregate_df = spark.read.table("WaterUtilizationAggregate")
updated_water_aggregate_df = convert_units(water_aggregate_df, uom_id_column='WaterUtilizationUnitOfMeasureId', value_columns=["WaterUtilization"], target_units=['litres'])
print(updated_water_aggregate_df)
