SAS 9.4 · origem
1 proc sql;
2 create table work.exposicao as
3 select cd_cliente,
4 sum(vl_exposicao) as vl_total,
5 put(dt_ref, yymmddn8.) as dt
6 from origem.posicao
7 group by cd_cliente, calculated dt;
8 quit;
PySpark · tentativa 2
1 # migratemind-step:step_019
2 exposicao = (origem_posicao
3 .groupBy("cd_cliente",
+ F.date_format("dt_ref", "yyyyMMdd").alias("dt"))
5 .agg(F.sum("vl_exposicao")
6 .alias("vl_total")))
- exposicao = exposicao.withColumn("dt", F.col("dt_ref"))
8 exposicao.write.saveAsTable("work.exposicao")