|
GitHub user aaltay opened a pull request:
https://github.com/apache/beam/pull/1872
BEAM-1349 Merge python-sdk to master
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/beam python-sdk
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/1872.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 #1872
commit 0a66721b5528483536eac753d5fc8cf28844b2eb Author: Maria Garcia Herrero <[email protected]> Date: 2016-11-22T17:57:50Z
Merge remote-tracking branch 'origin/master' into merge_master
commit cc706608b281c3beeebd2487084946c06bc83f30 Author: Mark Liu <[email protected]> Date: 2016-11-17T17:53:01Z
Support @ValidatesRunner(RunnableOnService) in Python [1/2]
commit 28bfd9090b0ce33c3da0bab0220fcc1ef8a72b4b Author: Thomas Groh <[email protected]> Date: 2016-11-22T18:11:22Z
This closes #1376
commit b4187bd91e9e53c1562ee845ffa87cc9e734006f Author: Kenneth Knowles <[email protected]> Date: 2016-11-22T20:08:38Z
This closes #1416
commit a6be102a9ebafd3e616ee6aca9a11fbb21c375d9 Author: Maria Garcia Herrero <[email protected]> Date: 2016-11-22T21:24:08Z
Remove tests for merge
commit 3b5cd0efc5f5e4b8fad34ee0d976e5e6ba501065 Author: Kenneth Knowles <[email protected]> Date: 2016-11-22T21:56:37Z
This closes #1384
commit 21f9c6d2cff052d662326ce73fdcf1fb08504dda Author: Kenneth Knowles <[email protected]> Date: 2016-11-22T23:31:10Z
This closes #1423
commit 2b69cce0f311a2ef40fdef4fe60d3e6fc13a8868 Author: Vikas Kedigehalli <[email protected]> Date: 2016-11-16T00:41:24Z
Add DatastoreIO to Python SDK
commit 9b9d016c80b9a7e73a7485d3e579ead3ada18ac6 Author: Davor Bonaci <[email protected]> Date: 2016-11-23T18:42:17Z
This closes #1398
commit 4dd19782f2624bf8aed3df8484fa314f94904571 Author: Kenneth Knowles <[email protected]> Date: 2016-11-16T05:33:13Z
Reject stateful DoFn in SparkRunner
commit 413a40243a30e059476395a2dcbfc98a94bb22f2 Author: Kenneth Knowles <[email protected]> Date: 2016-11-16T05:33:28Z
Reject stateful DoFn in FlinkRunner
commit 255ad9a327133ab4f05ebbceca236d5fe0006028 Author: Kenneth Knowles <[email protected]> Date: 2016-11-21T23:41:13Z
Add JUnit category for stateful ParDo tests
commit 1fc8d65a079e58d740a9b954da980963f20e9edf Author: Scott Wegner <[email protected]> Date: 2016-11-22T00:33:07Z
Update StarterPipeline
Convert StarterPipeline ParDo to MapElements.
Use the new DoFn for non-outputting transforms.
commit 796ba7ab75bc8d01a3a59efc29cdc17bcd26af4a Author: Kenneth Knowles <[email protected]> Date: 2016-11-16T05:33:01Z
Reject stateful DoFn in ApexRunner
commit 6fa8f658abaac1d3a983bfc3b8c09422159af8aa Author: bchambers <[email protected]> Date: 2016-11-22T19:37:23Z
Simplify the API for managing MetricsEnvironment
1. setCurrentContainer returns the previous MetricsEnvironment 2. setCurrentContainer(null) resets the thread local 3. scopedCurrentContainer sets the container and returns a Closeable to reset the previous container.
commit f03b4fe11cb605edf216903738a6c305b3a91066 Author: Thomas Groh <[email protected]> Date: 2016-11-22T22:51:39Z
Output Keyed Bundles in GroupAlsoByWindowEvaluator
This allows reuse of keys for downstream serialization.
commit dcd401ba0b5bd12343484b0df50b15b6ef10ace9 Author: Thomas Groh <[email protected]> Date: 2016-11-23T00:14:29Z
Add TransformHierarchyTest
This tests basic features of TransformHierarchy
commit 6f86af612f97ad57cf4ba2cae21ba232f7494ada Author: Kenneth Knowles <[email protected]> Date: 2016-11-23T06:16:29Z
Use more natural class to find class loader in ReflectHelpers
commit 2e03bb8a136078064014a0a7101960f6d2019487 Author: Thomas Weise <[email protected]> Date: 2016-11-22T19:38:00Z
Update transitive dependencies for Apex 3.5.0 snapshot version.
commit 3dbeb8edfdfe4c9e8987e4d8df4451fdb748dc07 Author: Davor Bonaci <[email protected]> Date: 2016-11-24T00:02:41Z
This closes #1432
commit d46203b7fcdc9895c9cee1d82710f48aba31a748 Author: Vikas Kedigehalli <[email protected]> Date: 2016-11-23T22:09:09Z
datastoreio write/delete ptransform
update datastore_wordcount example to include writes
commit 1530a17279d098ae7459f689ef02401f5116e54e Author: Dan Halperin <[email protected]> Date: 2016-11-28T23:54:27Z
Closes #1433
commit 7a059d37e71b62702e8cdeafec6956fc7e1e38c4 Author: Sourabh Bajaj <[email protected]> Date: 2016-11-21T23:50:21Z
Improve the speed of getting file sizes
commit ad4dc87a472387b507545ab80dbd2fe42e02cea3 Author: Davor Bonaci <[email protected]> Date: 2016-11-29T01:40:50Z
This closes #1404
commit 6c8c17a1c1977ed69860d25dc8ab45640e7a1c53 Author: Vikas Kedigehalli <[email protected]> Date: 2016-11-29T17:54:00Z
Update googledatastore version
commit 5ce75a2eae31dbab4d07d301716b4d7e3218b8b9 Author: Dan Halperin <[email protected]> Date: 2016-11-29T22:01:50Z
Closes #1453
commit 81e7a0f653864212a5c9d3d0802608f92bb34501 Author: Mark Liu <[email protected]> Date: 2016-11-17T22:45:42Z
Support ValidatesRunner Attribute in Python
This is roughly equivalent to "RunnableOnService" in the Java SDK. See BEAM-655
commit 70c1de9b95e9c20e5efb277d9ad50ae6348418e0 Author: Thomas Groh <[email protected]> Date: 2016-11-29T23:43:04Z
This closes #1382
commit 495a2d8c01949e4248d7e6dc9ad7a04168a292d1 Author: Vikas Kedigehalli <[email protected]> Date: 2016-11-29T18:02:14Z
Few datastoreio fixes
-
pin googledatastore version to 6.4.1
-
add num_shards options to datastore wordcount example
-
move datastore wordcount example to cookbook directory
commit aa9071d56120a1c0f91cc580fb956570113ee104 Author: Robert Bradshaw <[email protected]> Date: 2016-11-30T22:08:58Z
Closes #1454
|