GitHub user reuvenlax opened a pull request:
https://github.com/apache/beam/pull/2070
[BEAM-1530] Support record-determined output tables
Changes the existing tableRefFunction: BoundedWindow -> String, to a policy
that takes a Context object. This allows us to add further items to the policy
without breaking compatibility. This PR puts the window and the element in the
Context.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/reuvenlax/incubator-beam bq_dynamic_tables
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2070.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 #2070
----
commit 5b9ae1352832e8dfe4fc44ee924ac2654db9ac1a
Author: Reuven Lax <[email protected]>
Date: 2016-11-14T04:29:31Z
Add PubSub attributes support to PubsubIO.
commit 70f1321147c9755ef2c58b1c1eb293ec6ac38f55
Author: Reuven Lax <[email protected]>
Date: 2017-02-22T08:05:34Z
Fix CheckStyle issues
----
---
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.
---
