[ https://issues.apache.org/jira/browse/BEAM-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178821#comment-15178821 ]
ASF GitHub Bot commented on BEAM-94: ------------------------------------ GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/17 [BEAM-94] Add UnboundedCountingInput#withPeriod The period between elements controls the rate at which UnboundedCountingInput will output elements. This is an aggregate rate across all instances of the source, and thus elements will not necessarily be output "smoothly", or within the first period. The aggregate rate, however, will be approximately equal to the provided rate. Add package-private CountingSource.createUnbounded() to expose the UnboundedCountingSource type. Make UnboundedCountingSource package-private. You can merge this pull request into a Git repository by running: $ git pull https://github.com/tgroh/incubator-beam rate_limited_counting_source Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/17.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 #17 ---- commit 1db69553ac3fef93b56f4d52d02c30f170ca0698 Author: Thomas Groh <tg...@google.com> Date: 2016-02-29T21:48:09Z Add UnboundedCountingInput#withPeriod The period between elements controls the rate at which UnboundedCountingInput will output elements. This is an aggregate rate across all instances of the source, and thus elements will not necessarily be output "smoothly", or within the first period. The aggregate rate, however, will be approximately equal to the provided rate. Add package-private CountingSource.createUnbounded() to expose the UnboundedCountingSource type. Make UnboundedCountingSource package-private. ---- > CountingInput should be able to limit the rate at which output is produced > -------------------------------------------------------------------------- > > Key: BEAM-94 > URL: https://issues.apache.org/jira/browse/BEAM-94 > Project: Beam > Issue Type: Improvement > Components: sdk-java-core > Reporter: Thomas Groh > Assignee: Thomas Groh > -- This message was sent by Atlassian JIRA (v6.3.4#6332)