GitHub user reuvenlax opened a pull request:
https://github.com/apache/beam/pull/1926
[BEAM-1401] Allow unbounded windowed PCollections for FileBasedSinks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/reuvenlax/incubator-beam streaming_gcs_output
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/1926.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 #1926
----
commit 483b1c2c651abe8e0845a5e93331d655a0be5aaf
Author: Reuven Lax <[email protected]>
Date: 2016-11-14T04:29:31Z
Add PubSub attributes support to PubsubIO.
commit 266d63afb233e3b51357dbfb5f06c8500462d15a
Author: Reuven Lax <[email protected]>
Date: 2016-12-09T13:38:07Z
Add unbounded and windowing support to FileBasedSink
commit 6d884c2176f379062ce3cdd34470175b1cce09a9
Author: Reuven Lax <[email protected]>
Date: 2017-01-13T06:06:08Z
commit changes
commit 11e0400ee849716cc491a062d96849b864fed588
Author: Reuven Lax <[email protected]>
Date: 2017-01-13T21:10:34Z
Fix some errors
commit 8ea152f15801246f6e83c08fa3f10457b0be457b
Author: Reuven Lax <[email protected]>
Date: 2017-01-19T18:08:32Z
More updates
----
---
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.
---
