flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gaborhermann <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-2138] Added custom partitioning to Data...
Date Mon, 29 Jun 2015 16:44:23 GMT
Github user gaborhermann commented on the pull request:

    Okay, then I will
    * deprecate the partitioner implementation in the batch API
    * add the function implementation to the batch API
    * add the function implementation to the streaming API and remove the partitioner implementation
(so streaming will only have function implementation). As this PR is not merged yet we do
not break the streaming API.
    Is it okay?
    I guess it's worth it. This way Scala users will be able to write more concise code and
they will not get confused by the overloaded functions because the ones with the partitioner
will be deprecated.

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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message