阿里云实时计算平台Flink的作业开发流程详解

***************、РРproject='${projectName}',topic='${topicName}'Р);РCREATETABLEt_dim(РIDVARCHAR,РNAMEVARCHARРPRIMARYKEY(ID),РPERIODFORSYSTEM_TIME)WITH(Рtype='rds',Рurl='jdbc:mysql://*******************'userName='${userName}',password='${password}',tableName='t_dim'Р);РCREATETABLEt_animal_res(РIDVARCHAR,РNAMEVARCHAR,РNUM1INTEGER,РRQVARCHARРPRIMARYKEY(ID)Р)WITH(Рtype='rds',Рurl='jdbc:mysql://*******************'userName='${userName}',password='${password}',tableName='t_animal_res'Р);РINSERTINTOРt_animal_resРSELECTРB.ID,РB.NAME,РSUM(A.NUM1)ASNUM1,РSUBSTR(CAST(CURRENT_TIMESTAMPASVARCHAR),1,10)ASRQРFROMРt_animalAРJOINt_dimFORSYSTEM_TIMEASOFPROCTIME()ASBONA.ID=B.IDРWHEREР--按照数据同步时间进行where关联当天РSUBSTR(CAST(A.SMILESJASVARCHAR),1,10)=SUBSTR(CAST(CURRENT_TIMESTAMPASVARCHAR),1,10)РGROUPBYРB.ID,РB.NAME;