[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960585#comment-15960585
]
ASF GitHub Bot commented on FLINK-6090:
---------------------------------------
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/3696
[FLINK-6090] [table] Add RetractionRule at the stage of decoration
Add RetractionRules at the stage of decoration. These rules can derive
NeedRetraction property and accumulating mode. There are three rules:
1.InitProcessRule. This rule inits NeedRetraction property and AccMode for
DatastreamRels.
2.NeedToRetractProcessRule. This rule derives NeedRetraction property.
3.AccModeProcessRule.Find all AccRetract nodes. This rule derives
accumulating mode.
- [x] General
- The pull request references the related JIRA issue [FLINK-6090] Add
RetractionRule at the stage of decoration
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the
JIRA id)
- [ ] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [x] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis
build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hequn8128/flink FLINK-6090
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3696.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 #3696
----
commit c4edd908e2a251934ab6992dd1826a58a4d10b65
Author: hequn.chq <[email protected]>
Date: 2017-04-07T05:12:04Z
[FLINK-6090] [table] Add RetractionRule at the stage of decoration
----
> Add RetractionRule at the stage of decoration
> ---------------------------------------------
>
> Key: FLINK-6090
> URL: https://issues.apache.org/jira/browse/FLINK-6090
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Shaoxuan Wang
> Assignee: Hequn Cheng
>
> Implement optimizer for retraction:
> 1.Add RetractionRule at the stage of decoration，which can derive the
> replace table/append table, NeedRetraction property.
> 2.Match the NeedRetraction and replace table, mark the accumulating mode
>
> When this task is finished, we can turn on retraction for different operators
> according to accumulating mode.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
