leaf_engine.adapt.pipeline.adapt_oa_pipeline

Functions

_get_lane_volume_timeseries(→ pandas.DataFrame)
_get_weekday_combinations()
_subtract_base_from_base(base_df, other_base_df)
_subtract_base_from_volume(volume_df, base_df)
find_business_day_oppys(ships_df, **kwargs)
find_calendar_day_oppys(ships_df, **kwargs)
find_dow_oppys(ships_df, **kwargs)
find_weekly_oppys(ships_df, **kwargs)
oa_pipeline(...)

Module Contents

leaf_engine.adapt.pipeline.adapt_oa_pipeline._get_lane_volume_timeseries(ships_df: pandas.DataFrame, freq=None) → pandas.DataFrame

Parameters:

ships_df (pandas.DataFrame) –

Return type:

pandas.DataFrame

leaf_engine.adapt.pipeline.adapt_oa_pipeline._get_weekday_combinations()

leaf_engine.adapt.pipeline.adapt_oa_pipeline._subtract_base_from_base(base_df, other_base_df)

leaf_engine.adapt.pipeline.adapt_oa_pipeline._subtract_base_from_volume(volume_df, base_df)

leaf_engine.adapt.pipeline.adapt_oa_pipeline.find_business_day_oppys(ships_df, **kwargs)

leaf_engine.adapt.pipeline.adapt_oa_pipeline.find_calendar_day_oppys(ships_df, **kwargs)

leaf_engine.adapt.pipeline.adapt_oa_pipeline.find_dow_oppys(ships_df, **kwargs)

leaf_engine.adapt.pipeline.adapt_oa_pipeline.find_weekly_oppys(ships_df, **kwargs)

leaf_engine.adapt.pipeline.adapt_oa_pipeline.oa_pipeline(etl_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptETLContext) → leaf_engine.adapt.context.adapt_contexts.AdaptOAContext

Parameters:

etl_cxt (leaf_engine.adapt.context.adapt_contexts.AdaptETLContext) –

Return type:

leaf_engine.adapt.context.adapt_contexts.AdaptOAContext