GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2675
[FLINK-4504][dataset api]Support user to decide whether the result of an
operator is presistent
This pr is based on #2674 , it add an setOptions() interface to the class
Operator, so user can
calltext.flatMap().setOptions(ConfigConstants.OPERATOR_RESULT_PERSISTENT_TYPE ,
"DFS") to specify that the result of flaMap() should be put to DFS.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/alibaba/flink jira-4504
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2675.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 #2675
----
commit b0c4ed17c441e0bb7985afeea9288d601ea89897
Author: shuai.xus <[email protected]>
Date: 2016-10-20T08:34:45Z
[FLINK-4504][dataset api]Support user to decide whether the result of an
operator is presistent
commit 7deeba0698923eb6af2f40e2cd9f0791cb288759
Author: shuai.xus <[email protected]>
Date: 2016-10-21T08:04:26Z
[FLINK-4504][dataset api] fix unittest fail
----
---
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.
---
