You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jkff <gi...@git.apache.org> on 2017/08/17 01:23:40 UTC
[GitHub] beam pull request #3725: Introduces AvroIO.watchForNewFiles
GitHub user jkff opened a pull request:
https://github.com/apache/beam/pull/3725
Introduces AvroIO.watchForNewFiles
This PR includes a couple more related minor cleanups. I've split each of them into separate commits for easier reviewing.
There's a bunch of boilerplate required for adding these features to each of the 4 read transforms in AvroIO, and it duplicates respective boilerplate in TextIO. I think for now it's not enough of a problem to do anything about it.
R: @reuvenlax
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jkff/incubator-beam avro-watch
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/3725.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 #3725
----
commit 22384fe24f72a0fee306860bf1bf617e27360346
Author: Eugene Kirpichov <ek...@gmail.com>
Date: 2017-08-16T21:25:33Z
Gets rid of raw type in TextIO.Read.watchForNewFiles
commit c9f2f09585c5a2a9120f4c110d4c266372451c9a
Author: Eugene Kirpichov <ek...@gmail.com>
Date: 2017-08-16T21:29:52Z
Better-organized javadocs for TextIO and AvroIO
commit 27fa8f8125596baac9c1013ef7da20c7ec137ed8
Author: Eugene Kirpichov <ek...@gmail.com>
Date: 2017-08-16T21:40:52Z
Adds EmptyMatchTreatment to AvroIO
commit 0d7dce60f4e4cde439fbf7804e194a5a59856b22
Author: Eugene Kirpichov <ek...@gmail.com>
Date: 2017-08-16T21:41:32Z
Adds AvroIO watchForNewFiles
commit fec7591cdadbb5f637d32c5e34bbf9b5bdd3eb44
Author: Eugene Kirpichov <ek...@gmail.com>
Date: 2017-08-17T00:50:25Z
Fixes a findbugs error in Apex runner
----
---
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.
---
[GitHub] beam pull request #3725: [BEAM-2827] Introduces AvroIO.watchForNewFiles
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/beam/pull/3725
---
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.
---