+ Implementation for aggregate dataset observation processor
+ Some refactoring