transformation.transformations

Submodules

• transformation.transformations.base
• transformation.transformations.fare_metrics
• transformation.transformations.speed
• transformation.transformations.time_features

Classes

SpeedTranfromation	Base Transformation to be inherited from while defining the transformations
FateMetricTranfromation	Base Transformation to be inherited from while defining the transformations
TimeFeaturesTransforamtion	Base Transformation to be inherited from while defining the transformations

Package Contents

class transformation.transformations.SpeedTranfromation

Bases: transformation.transformations.base.BaseTranformation

Base Transformation to be inherited from while defining the transformations

apply(df: pyspark.sql.DataFrame) → pyspark.sql.DataFrame

class transformation.transformations.FateMetricTranfromation

Bases: transformation.transformations.base.BaseTranformation

Base Transformation to be inherited from while defining the transformations

apply(df: pyspark.sql.DataFrame) → pyspark.sql.DataFrame

Calculate simple fare metrics as fare per km and fare per minute :param - df: the dataframe to extract informations from :type - df: DataFrame

Returns:

the enriched dataframe

Return type:

• res (DataFrame)

class transformation.transformations.TimeFeaturesTransforamtion

Bases: transformation.transformations.base.BaseTranformation

Base Transformation to be inherited from while defining the transformations

apply(df: pyspark.sql.DataFrame) → pyspark.sql.DataFrame