The Big Data in Real World team does some counting:
We want to group the dataset by Name and get a count to see the employee and the number of projects they are assigned to. In addition to that sub count, we also want to add a column with a total count like below.
One important thing to remember about Spark transformations is that they’re lazy: just because you ran df.groupBy(...).agg(...)
doesn’t mean the new DataFrame exists yet, so until you call the show()
action (or whatever), the original data is still there for the taking, which is how you can reference it again later in the chained statement.