...
Primeiramente, são criadas as duas databases que serão utilizadas no projeto. Na database margin_analysis ficarão as views para serem consumidas para o pelo projeto e na database margin_analysis_temp ficarão as tabelas temporárias criadas nesse neste processo.
| Code Block | ||
|---|---|---|
| ||
spark.sql("""create database if not exists margin_analysis""")
spark.sql("""create database if not exists margin_analysis_temp""") |
...