GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1929
Watch type proper
This PR is for FLINK-3808. It refactor the FileMonitoring sources to take
as an argument a FileInputFormat and work at the granularity of a split, and
not at that of a file. It still does not change the API calls, which still
call the old code. This will come in a following PR.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink watch_type_proper
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1929.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 #1929
----
commit f3b96b72eae877002fcd5f4699575d0e7cd928d4
Author: kl0u <[email protected]>
Date: 2016-04-18T14:37:54Z
First commit in implementing the Monitor.
commit c4f6f8c94b8501853a9fb06097b18fc378ea62ec
Author: kl0u <[email protected]>
Date: 2016-04-19T11:07:08Z
ToRemove
commit 2405a2131a84d42fac25d34fb5c32d30a5710d64
Author: kl0u <[email protected]>
Date: 2016-04-19T12:00:27Z
Removed unused classes.
commit 80ce550134d968fa833ddb3219d64d2bbe902318
Author: kl0u <[email protected]>
Date: 2016-04-19T13:03:01Z
Reverted classes back to master version.
commit f7a89c90aee28d0d8fa074a3319318b32617e494
Author: kl0u <[email protected]>
Date: 2016-04-19T16:24:18Z
A version of the monitor.
commit b9ed3159beed5a08ec96876c8d43781a738da3cb
Author: kl0u <[email protected]>
Date: 2016-04-20T13:27:09Z
A non-faultolerant version that compiles.
commit 2ab79bf158d6974eea0f4220c51fc8d8e6c767dd
Author: kl0u <[email protected]>
Date: 2016-04-20T14:46:27Z
Adding checkpointing functionality.
commit d920fadaefa64f16342359430cbc831c94a8321c
Author: kl0u <[email protected]>
Date: 2016-04-20T15:49:48Z
Adding Tests.
commit f82948161317000bf5f4018c492e12df2f6237d9
Author: kl0u <[email protected]>
Date: 2016-04-22T11:56:13Z
Fixed Reader bug.
commit 58df5ae96d48470c944ef2852b606bffe6bcbd70
Author: kl0u <[email protected]>
Date: 2016-04-24T11:16:07Z
Restructuring the tests.
commit a10109354ea8858c94c04758d5f849fa738532c7
Author: kl0u <[email protected]>
Date: 2016-04-24T21:19:11Z
Adding the map with the timestamp.
----
---
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.
---
