GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2871
[FLINK-5163] Ports the production functions to the new state abstraction.
This includes the following functions:
1) `StatefulSequenceSource`
2) `MessageAcknowledgingSourceBase`
3) `FromElementsFunction`
4) `ContinuousFileMonitoringFunction`
Each of them is a separate commit, for ease of reviewing.
Most of the functions assume parallelism of 1. The only exception is the
`StatefulSequenceSource`.
R @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink dop1-source-rescaling
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2871.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 #2871
----
commit 3a436c5ef7d0123f0f244700f8a62bb325fac118
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-17T13:54:08Z
[FLINK-5163] Port the ContinuousFileMonitoringFunction to the new state
abstractions.
commit a49fce791553c94dc866140c7616f52354d788fc
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-17T15:52:50Z
[FLINK-5163] Port the FromElementsFunction to the new state abstractions.
commit ecee88819bc7be09681047fc0f8c2e347ddbdd06
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-18T15:07:45Z
[FLINK-5163] Port the MessageAcknowledgingSourceBase to the new state
abstractions.
commit 1dde7c7d7b978cfac086ee93eb775069763b7788
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-21T17:50:30Z
[FLINK-5163] Port the StatefulSequenceSource to the new state abstractions.
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
