first you use an aggregrate and group it by all the columns from source. then add one more column in aggregrator which actualy aggregrate the count of each group.then after that either using filter...