flink1.12-sql??current_date??????????????????

?????? Mon, 11 Jan 2021 20:34:25 -0800
????idea??????flink-sql??????current_date????????????????????????????????????????????????????????????????????????????group
 by 
current_date,id??????????????????mysql????????????????????current_date????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
??????????--------------------------------------------
|insert into dwd_worktask_info
|select
|     cccti.Id,
|     cccti.WorkName,
|     cccti.CustomerId,
|     cccti.HandlerOrgId,
|     ccctmd.LastHandlePersonId,
|     ccctmd.LastDistributionTime,
|     ccctmd.LastHandleOrgId
|     currnet_date as As_Of_Date
|     from cc_task_info cccti
|join cc_task_****_dis  ccctmd on cccti.Id=TaskInfoId   and ccctmd.IsDeleted=0  
and ccctmd.CreateTime&gt;cast(current_date as TimeStamp)
|where cccti.IsDeleted=0 and cccti.DistributionTime&gt;cast(current_date as 
TimeStamp)
????????----------------------------------------------------------------------------------------------|insert
 into app_bs_drainage_place
|SELECT
|     do.GrouporgName,
|     du.Name,
|     COUNT(DISTINCT dooi.Code) AS Total,
|     md5(concat(do.GrouporgName,du.Name,cast(dwi.As_Of_Date as String))) as 
uuids,
|     dwi.As_Of_Date as As_Of_Date
|FROM dw_od_order_info dooi
|INNER JOIN dwd_worktask_info dwi ON dwi.CustomerId = dooi.CustomerId AND 
dwi.HandlerPersonId = dooi.UserId and dwi.As_Of_Date=current_date
|INNER JOIN dim_cc_***** dmplr ON dmplr.MediaPlacementId = dwi.PlacementId
|INNER JOIN dim_*** dcml ON dmplr.LabelId = dcml.Id
|INNER JOIN dim_user_**** du ON dooi.UserId = du.Id
|INNER JOIN dim_org_**** do ON dooi.UserOrgId = do.Grouporgid
|WHERE dooi.OrderTime&gt;cast(current_date as TIMESTAMP) and dooi.Status <&gt; 
60 AND dooi.Status <&gt; 120 AND dooi.OrgType = 1
|GROUP BY dwi.As_Of_Date,do.GrouporgName,du.Name
flink1.12-sql??current_date??????????????????

回复
