CorrelationReduce version 1.8, CorrelationMap version 1.9
SELECT * FROM CorrelationReduce ( ON CorrelationMap ( ON { table | view | (query) } [ PARTITION BY group_column [, group_column [,...]] ] USING TargetColumns ({ 'target_column' | target_column_range }[,...]) KeyName ('key_name') [ GroupByColumns ({ 'group_column' | group_column_range }[,...]) ] ) PARTITION BY key_name [, group_column [,...]] ) AS alias;