店拆分优化
2023-08-03 17:51:49 0 举报
店拆分节点优化
作者其他创作
大纲/内容
计算ss
这三个减少中间算子
可配送日期
减少中间算子
拼接越库_预计算
天行转列
优化前:60*20+10=1230G;5*20+1=101core
scm_location_map
门店商品下架时间
供应商箱规
保质期_最小陈列量
拼接可配送日期
CD类商品
优化sql脚本
防呆机制-锁鲜装数据
拼ware_code
只保留店逻辑
昨天真实库存
库存计划报表
可下单日期
scm_note_sku_property
下月品类宽度_去重
仓箱规
replishment_all_new
dim_sku
scm_lyf_day_off_date
fact_inventory_stock_onhand
product_all_channel_kpi
zzqdl_yu_vlt
日预测补货结果接口
优化SQL语句
test_计算库存计划demand等
连接进货权限
scm_sku_store_minmax_conf
scm_sku_mgr
zt_ic_store_purchase_access
可下单日期123
供应商最小起送量
zt_ic_sku_unit_type
get_real_avg_天平均销量
fact_trade_order_item_temp
动态输出所有字段
计算箱规
保留店逻辑,并将is_kbh逻辑放到后续修改ti_计算补货量的节点
replishment_all(取第一片)
整体优化:在保证每个算子资源能满足运行条件,且运行时间与优化前几乎一致的情况下,减少资源的消耗,在集群计算资源并行度较高的时段能优化整体的运行效率:以天行转列算子为例
将取重复和去掉重复合并为一个算子,且sql表达更加清晰
zt_sc_kp_rw_relation
拼接类目
sku_store_ware
rundate是不是可补货日期
scm_width_sku
优化sql
只取第一分片,店数据,去掉数据组合并
zt_ic_sku
dim_store
拼接可下单日期
修改最小陈列量计算逻辑,修改整体pyspark代码,去掉无效代码块
predict_sale_num(仓店)
拼接销售面积_装修风格_存储类型
销量汇总
kp_scm_forecast_onroad_record
优化后:12*6+6=78g;6*6+1=37core
取sku_key
拼warehouse_id
dim_channel
sales
sku_level_config
zt_ic_sku_attribute
replishment_all
拼接vlt等_创建字段
store_sales_ware
test_计算约束
天作左表leftjoin
dim_store_level
修改整体pyspark代码,去掉无效代码块
scm_notes_sku_property
replishment_all(1-28切片)
只取门店
scope修正
拼接下架日期_计算销量修正
日库存计划
8天内新品
scm_width
zt_ic_sku_category
计算销量修正
zxcll_ryxs_zjts
zt_ic_sku_unit
node_sku_replish
拼接可补货日期
new_skusto_presample
可补货日期123
scm_warehouse_capacity
sum14
可配送日期123
leftjoin
scm_sku_store_level_minmax_conf
可补货日期
MAPE
门店在途库存
合并1-20切片
减少中算子
拼在途和库存
取14天数据
取最大理论库容
门店在途
最大仓容
dim_warehouse
计算ss03
zt_ic_unit
聚合商品单位等
leftjoin_minmax
只取店数据的逻辑,减少中间算子,优化
计算库存水位
修改ti_计算补货量
减少中间算子,去掉sku_level_config的数据合并
门店28天平均销量
把scm_sku_mgr过滤节点去掉逻辑放在leftjoin,并将leftjoin中的仓相关逻辑去掉
0 条评论
下一页