????????????flink??????????????????????????????????flink-on-yarn??????????job????????????????????????????????????????????????????????????????????TimeStamp>current_date????????????????????????????????????????????????????????????????????????????????????????env.setStateBackend(new
MemoryStateBackend())??????????????????????job??????????????????State??????????????????????????????????connector??upsert-kafka??????????dwd??????sql????????????????????sql????????????????????dwd????upsert-kafka????????
| select
| TO_DATE(cast(doi.DeliveryTime as String),'yyyy-MM-dd')
as days,
| doi.UserId,
| count(doi.Code) as SendTime,
| sum(doi.PayAmount / 100) as SendCashcharge,
| sum(doi.PayAmount / 100 - ChargeAmount / 100 +
UseBalance / 100) as SendCashuse,
| sum(doi.CashMoney / 100)as SendCash
| from dwd_order_info doi
| where doi.DeliveryTime >cast(current_date AS TIMESTAMP)
and doi.OrderType = 29 and doi.Status >= 50 and doi.Status <> 60
| group by TO_DATE(cast(doi.DeliveryTime as
String),'yyyy-MM-dd'), doi.UserId
