Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/275#issuecomment-68049822
Concerning the project structure: For the batch part, there are discussions
to combine the "flink-core", "flink-java" projects, possibly also the
"flink-scala" project. We are starting to see too many interdependencies.
May be good to keep in mind when you decide on a project structure.
We could, in the next version, go for something like
- flink-core (core and batch, java & scala)
- flink-streaming (java & scala)
- flink-runtime
- ...
Am 23.12.2014 21:52 schrieb "Gyula Fora" <[email protected]>:
> Okay as @aljoscha <https://github.com/aljoscha> and @rmetzger
> <https://github.com/rmetzger> suggested I reworked our grouping and
> removed the extra classes and substituted them with the use of Keys from
> the batch API, works well and looks good :)
>
> The only thing I left in is the ArrayKeySelector which we use in the
> Streaming api to allow grouping and aggregating on array types as well.
>
> Let's merge this soon because I am also pushing out a rework of the
> streaming sources for better parallelism handling and also on the
> connectors to other systems which builds on this PR.
>
> â
> Reply to this email directly or view it on GitHub
> <https://github.com/apache/incubator-flink/pull/275#issuecomment-67997069>
> .
>
---
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.
---
