I’m trying to merge the AML fork and looked deeper into the cleanup app, which we turned into a optional feature of any Datasource. In the cleanup app example it uses an RDD.collect, which is not scalable. It seems that PEvents does not really support delete so you have to get the `eventsToDelete` as an RDD then collect before you can actually delete and use LEvents to do it. Is this reasoning correct?
If so I think we will need get an RDD of `eventsToDelete` (done) then create a new method on PEvents that deletes them. Does this sound right? Any advise on this would be helpful because I think it would block a merged release.
