| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889 |
- # nodes, start, end 是必须有的属性
- comment: "组件串联demo"
- # 全局配置
- conf:
- # 预测长度
- forecast_periods: 10
- # 预测粒度
- forecast_freq:
- enumType: yibu.core_model.TimeDimensionEnum
- enumName: Daily #Daily Weekly Monthly
- # 预测起始长度，如果预测时常是3-6月，forecast_start=3
- forecast_start: &forecast_start 0
- # 预测日期
- forecast_day: 2022-07-20
- # 是否处于测试模式
- debug: True
- # 是否本地模式
- run_local: False
- # 资源配置
- excutors_nums: 1
- excutors_cores: 3
- nodes:
- # 获取订单数据
- orderSrc:
- type: yibu.csv_io.CSVSource
- conf:
- path: "t_order_demo.csv"
- # 动销过滤
- nonSale:
- type: yibu.filter.non_sale_jh3.NonSaleFilter
- conf:
- able: True # 配置是否使用动销过滤
- num_day: 90 # 配置动销过滤天数
- in:
- - orderSrc: 0
- # 订单汇销量
- orderToSale:
- type: yibu.filter.order_aggregation_jh3.OrderAggregationFilter
- conf:
- forecast_freq: # 预测粒度
- enumType: yibu.core_model.TimeDimensionEnum
- enumName: Daily
- repartition: True
- padding: True # 是否对没有销量的日期填0
- in:
- - nonSale: 0
- # 简单移动平均预测
- simpleMovingAverage:
- type: yibu.filter.user_sma_zby.UserSmaFilter
- conf:
- moving_steps: 7 #第一个天数
- moving_steps2: 14 #第二个天数
- SMA1_weight: 0.6 #第一个比例
- SMA2_weight: 0.4 #第二个比例
- sum_weight: 1.0 # 整体比例
- in:
- - orderToSale: 0
- # 预测结果写表
- writeFcstData:
- type: yibu.csv_io.CSVDestination
- conf:
- path: "result_demo.csv"
- in:
- - simpleMovingAverage: 0
- # 流程图的 开始和结束 结点
- start: orderSrc
- end: writeFcstData
- # 这里设置Spark 相关的配置
- spark:
- appName: jh3
- spark.speculation: false
- spark.sql.adaptive.skewedJoin.enabled: false
- spark.sql.hive.mergeFiles: true
- spark.sql.adaptive.enabled: false
- spark.sql.adaptive.join.enabled: false
- spark.sql.crossJoin.enabled: true
- hive.metastore.uris: thrift://10.116.1.72:9083
|
