GitHub user fyellin opened a pull request:
https://github.com/apache/incubator-beam/pull/841
[Beam-556] Fix typo in documentation
This is my first python submission. It was built on top of
origin/python-sdk rather than origin/master. If I'm doing this wrong, please
let me know.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fyellin/incubator-beam beam-556
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/841.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 #841
commit 87ca53927706510dd643ae8b2d85894f713b0550
Author: Jesse Anderson
Date: 2016-05-16T20:58:08Z
Changed Word Counts to use TypeDescriptors.
commit 21a87f96511ec1b2b696402bec220f7b984fe600
Author: Scott Wegner
Date: 2016-05-16T21:01:43Z
Add configuration for Dataflow runner System.out/err
commit d32179870c61e57dd5ce4287675ae4421a9249d2
Author: Jesse Anderson
Date: 2016-05-16T21:09:18Z
Updated complete examples to use TypeDescriptors.
commit c7911fb23a60128b096acb8462b2fe94aea52061
Author: Scott Wegner
Date: 2016-06-09T18:31:23Z
Make example AddTimestampFn range deterministic
The timestamps added in the WindowedWordCount example are currently
based on when the bundles are executed, which makes the min/max bounds
non-deterministic. This change makes the range based on the
construction time.
commit cc8700b016fd1db7db3a3483068f8633d436b64d
Author: Kenneth Knowles
Date: 2016-06-13T01:29:46Z
Add success/failure counters to new PAssert mechanism
commit 5e6b35fd5c2f40bfdf46dc308d9750f85d5d7fed
Author: Scott Wegner
Date: 2016-06-13T18:05:00Z
Fix AutoComplete example streaming configuration
commit 99441b418e6e18ca34e0413f94f1d939393e2273
Author: manuzhang
Date: 2016-06-13T03:09:38Z
[BEAM-336] update examples-java README
commit 1f66cbf08cf18047ce67ea4eaa95dcea6872a532
Author: Thomas Groh
Date: 2016-05-18T23:56:06Z
Update the Default Pipeline Runner
Select the InProcessRunner if it is on the classpath, and throw an
exception otherwise.
commit 3df522f8b964bdcbf559de27221f9e2ce15c12c4
Author: Thomas Groh
Date: 2016-06-10T21:36:42Z
Update Pipeline Execution Style in WindowedWordCountTest
This sets the runner a Pipeline creation time rather than sending a
(potentially rewritten) pipeline to a new runner instance.
commit 9cf1d24d910b2f00ac3dbacc792c9f1d3fc053e0
Author: Thomas Groh
Date: 2016-06-10T21:38:36Z
Update Direct Module tests to explicitly set Pipeline
commit 140519c8291f9f3a5135b868343aa9b4181889bd
Author: Thomas Groh
Date: 2016-06-10T21:41:06Z
Use TestPipeline#testingPipelineOptions in IO Tests
commit febf4a14d741f3a9eb1706f8ebdb8d9a9469d3bc
Author: Thomas Groh
Date: 2016-06-10T21:43:10Z
Move GcsUtil TextIO Tests to TextIOTest
These tests are not a test of the DataflowRunner, nor any
DataflowRunner specific behavior, so they should be part of TextIOTest
commit cce4dcabe30b109095365830b4d10c300335e17b
Author: Thomas Groh
Date: 2016-06-10T21:45:58Z
Set Runner in DataflowRunner Tests
Otherwise the Default Runner is used, which may be unavailable.
commit 59371181a0d5af55364840842617c8aa082945a0
Author: Thomas Groh
Date: 2016-06-10T21:47:53Z
Increase Visibility of Flink Test PipelineOptions
This fixes an issue where the package-private nature would cause an
exception
commit 882e8f8bcfc0adc71e9a2bcb969c61328830b910
Author: Dan Halperin
Date: 2016-06-14T00:34:58Z
CompressedSourceTest: simplify
We should use random.nextBytes(buff) instead of making the array in a loop.
The code we now point to is the same as the for loop, so the test continues
to pass.
commit 8cab792563302cd2863868ce209d63dc82eeebf0
Author: Kenneth Knowles
Date: 2016-06-14T15:05:04Z
Revert GBK-based PAssert
This changed neglected the use of counters by the Dataflow runner,
which is used to prevent tests for spuriously passing when
a PCollection is empty.
Obvious fixes for that revealed probable bugs in the in-process
and Spark runner, as well as tests that happen to work with
PAssert but are actually unsupported.
A proper long-term fix is underway to address all of the above.
In the meantime, this commit rolls back the changes to PAssert.
commit ecf6ab8097e4ce9a69463578dd74841febc7d84d
Author: Thomas Groh
Date: 2016-06-14T20:18:41Z