refactored ProcessEach in datafun.go more
implemented aggregate/product