GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/6120
[FLINK-7251] [types] Remove the flink-java8 module and improve lambda type
extraction
## What is the purpose of the change
This PR merge the `flink-java8` module into `flink-core`/`flink-runtime`.
It also fixes issues with lambda extraction that occurred outside of
`flink-java8` which used a different compiler.
Lambdas are still difficult to use in Flink. I'm working on an experimental
solution that I will publish soon.
## Brief change log
- Integration of some lambda functions into existing examples/tests
- Removal of error-prone lambda input validation
- Removal of `flink-java8`
- Code clean up (remove warnings at several places)
## Verifying this change
This change is already covered by existing tests, such as
`LambdaExtractionTest`.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): yes
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/twalthr/flink FLINK-7251_1
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/6120.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 #6120
----
commit 0710fd42c321964dbf523878f59f82624baee597
Author: Timo Walther <twalthr@...>
Date: 2018-06-04T10:49:43Z
[FLINK-7251] [types] Remove the flink-java8 module and improve lambda type
extraction
----
---
