Skip to content

Commit

Permalink
Merge branch 'develop'
Browse files Browse the repository at this point in the history
  • Loading branch information
jterry64 committed Mar 30, 2020
2 parents dcdb289 + 5e4576c commit 1fab045
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -273,15 +273,15 @@ object AnnualUpdateMinimalExport extends SummaryExport {

exportDF
.transform(AnnualUpdateMinimalDF.aggSummary(idCols))
.coalesce(33) // this should result in an avg file size of 100MB
.coalesce(4) // this should result in an avg file size of 100MB
.write
.options(csvOptions)
.csv(path = outputUrl + "/geostore/summary")
}
exportDF
.filter($"treecover_loss__year".isNotNull && $"treecover_loss__ha" > 0)
.transform(AnnualUpdateMinimalDF.aggChange(idCols))
.coalesce(50) // this should result in an avg file size of 100MB
.coalesce(10) // this should result in an avg file size of 100MB
.write
.options(csvOptions)
.csv(path = outputUrl + "/geostore/change")
Expand Down

0 comments on commit 1fab045

Please sign in to comment.