GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1600
[FLINK-3226] Translate logical aggregations to physical
This PR builds on #1567 and addresses @fhueske's comments on translating
aggregations.
Join translation is not part of this PR.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink LogicalToPhysical
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1600.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1600
----
commit 6676aab520bd648c360f70a2047196d004ce1d31
Author: chengxiang li <[email protected]>
Date: 2016-02-01T07:18:14Z
[Flink-3226] Translate logical plan FlinkRels into physical plan
DataSetRels.
commit cf41b740d32768185ec692e93754056ff6a16b59
Author: vasia <[email protected]>
Date: 2016-02-04T14:53:52Z
[FLINK-3226] implement GroupReduce translation; enable tests for supported
operations
- compute average as sum and count for byte, short and int type to avoid
rounding errors
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---