Description
The basic metric can be the number of tuples that is flowing through. We can add more metrics later.
In order for this to work, we can add a new "accumulators" method to SparkPlan that defines the list of accumulators, .e.g.
def accumulators: Map[String, Accumulator]