[3/3] incubator-beam git commit: Closes #1241

Closes #1241 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13dd9ff4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13dd9ff4 Diff:

[GitHub] incubator-beam pull request #1241: Windowed value coder

Github user robertwb closed the pull request at: https://github.com/apache/incubator-beam/pull/1241 --- 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

[2/2] incubator-beam git commit: Improvements related to size estimation.

Improvements related to size estimation. Updates FileBasedSource so that size estimation of glob patterns that expand into a large number of files is done using sampling. Updates Dataflow runner to set estimated sizes of sources when submitting jobs. Project:

[GitHub] incubator-beam pull request #1241: Windowed value coder

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1241 Windowed value coder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[1/2] incubator-beam git commit: Closes #1235

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 13dd9ff49 -> b33fdfdad Closes #1235 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b33fdfda Tree:

[1/2] incubator-beam git commit: Fixes two bugs in avroio_test 'test_corrupted_file'.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 7e870613f -> 9d2acc98e Fixes two bugs in avroio_test 'test_corrupted_file'. (1) Updates test to perform corruption properly (setting 'A' and 'B'). (2) Removes an invalid usage of bytearray(). Project:

[2/2] incubator-beam git commit: Closes #1267

Closes #1267 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d2acc98 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9d2acc98 Diff:

[2/3] incubator-beam git commit: Add unittests for BQ 2.0

Add unittests for BQ 2.0 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ce3f1726 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ce3f1726 Diff:

[1/3] incubator-beam git commit: Closes #1242

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 7270471bf -> 96c228675 Closes #1242 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96c22867 Tree:

[3/3] incubator-beam git commit: BEAM-873 Support for BigQuery 2 SQL

BEAM-873 Support for BigQuery 2 SQL Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0a339653 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0a339653 Diff:

[1/2] incubator-beam git commit: Updated readme according to BEAM-693

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 9d2acc98e -> 7270471bf Updated readme according to BEAM-693 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/43740a47 Tree:

[2/2] incubator-beam git commit: Closes #1245

Closes #1245 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7270471b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7270471b Diff:

[GitHub] incubator-beam pull request #1274: Implement key range tracker.

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1274 Implement key range tracker. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[1/3] incubator-beam git commit: Checking for integer types in json conversion

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 96c228675 -> a6e104d6d Checking for integer types in json conversion Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3321064e Tree:

[3/3] incubator-beam git commit: Closes #1273

Closes #1273 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a6e104d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a6e104d6 Diff:

[2/3] incubator-beam git commit: Adding unit tests

Adding unit tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b30208be Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b30208be Diff:

[2/3] incubator-beam git commit: Document the input and output of type conversions

Document the input and output of type conversions Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/456f9263 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/456f9263 Diff:

[3/3] incubator-beam git commit: Make the BQ input for dataflow runner and local runner is identical for time related types

Make the BQ input for dataflow runner and local runner is identical for time related types Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d66cb174 Tree:

[1/3] incubator-beam git commit: Closes #1250

Repository: incubator-beam Updated Branches: refs/heads/python-sdk a6e104d6d -> 32d719911 Closes #1250 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/32d71991 Tree:

[07/50] [abbrv] incubator-beam git commit: Remove pieces of Trigger now owned by TriggerStateMachine

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1eff320d/sdks/java/core/src/test/java/org/apache/beam/sdk/util/FinishedTriggersProperties.java -- diff --git

[50/50] [abbrv] incubator-beam git commit: Closes #1198

Closes #1198 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/57f03f79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/57f03f79 Diff:

[48/50] [abbrv] incubator-beam git commit: Merge branch 'master' into py_merge_master

Merge branch 'master' into py_merge_master Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/02b5b4c9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/02b5b4c9 Diff:

[45/50] [abbrv] incubator-beam git commit: Port some example utils from OldDoFn to DoFn

Port some example utils from OldDoFn to DoFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3bec5e03 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3bec5e03 Diff:

[01/50] [abbrv] incubator-beam git commit: Closes #1168

Repository: incubator-beam Updated Branches: refs/heads/python-sdk c37b89ec7 -> 57f03f793 Closes #1168 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44b9f4eb Tree:

[44/50] [abbrv] incubator-beam git commit: Remove checked exceptions from PipelineResult.waitUntilFinish interface.

Remove checked exceptions from PipelineResult.waitUntilFinish interface. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1559a7f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1559a7f4

[49/50] [abbrv] incubator-beam git commit: update parent pom version in python/pom.xml

update parent pom version in python/pom.xml Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/654b848b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/654b848b Diff:

[42/50] [abbrv] incubator-beam git commit: Closes #1181

Closes #1181 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/09a80ecb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/09a80ecb Diff:

[16/50] [abbrv] incubator-beam git commit: Remove unused GroupAlsoByWindowsDoFn.createDefault

Remove unused GroupAlsoByWindowsDoFn.createDefault Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ce3aac2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5ce3aac2 Diff:

[32/50] [abbrv] incubator-beam git commit: Add utility to handle JSON option manipulation

Add utility to handle JSON option manipulation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/35244a68 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/35244a68 Diff:

[46/50] [abbrv] incubator-beam git commit: This closes #1173

This closes #1173 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/25102f79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/25102f79 Diff:

[25/50] [abbrv] incubator-beam git commit: [BEAM-799] Support GroupByKey directly.

[BEAM-799] Support GroupByKey directly. Remove runner override for GroupByKey. Avoid NPE if no sideInputs are available in reader. Handle CombineFn with or without context. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[29/50] [abbrv] incubator-beam git commit: Revert "Fix invalid snapshot repo in Travis CI's maven settings.xml"

Revert "Fix invalid snapshot repo in Travis CI's maven settings.xml" This reverts commit fbc23ed9234088c9d88bf88b19a3a4d6d5e52446. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3c71e4da Tree:

[11/50] [abbrv] incubator-beam git commit: This closes #1174

This closes #1174 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c03e3e92 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c03e3e92 Diff:

[41/50] [abbrv] incubator-beam git commit: Streamline Travis CI build

Streamline Travis CI build Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5c558e6f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5c558e6f Diff:

[47/50] [abbrv] incubator-beam git commit: [BEAM-813] support metadata in Avro sink

[BEAM-813] support metadata in Avro sink Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eba099f5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eba099f5 Diff:

[21/50] [abbrv] incubator-beam git commit: This closes #1178

This closes #1178 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13af296d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13af296d Diff:

[36/50] [abbrv] incubator-beam git commit: [BEAM-816] Aggregators are not properly named when reported to Graphite.

[BEAM-816] Aggregators are not properly named when reported to Graphite. Added NamedAggregatorTest. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6db94249 Tree:

[34/50] [abbrv] incubator-beam git commit: [BEAM-658] Support Read.Unbounded primitive.

[BEAM-658] Support Read.Unbounded primitive. Changed mapSourceFunction to use scala's native Option. Upgrade to kryo-serializers 0.39 that provides support for ReverseList (used by Top). Better logging. Allow a longer read time-frame for read in tests. Assert initial parallelism is gerater

[38/50] [abbrv] incubator-beam git commit: Use project-wise version in SparkRunner dep on KafkaIO

Use project-wise version in SparkRunner dep on KafkaIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d6598d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9d6598d3 Diff:

[17/50] [abbrv] incubator-beam git commit: Add experimental ServiceAccount option

Add experimental ServiceAccount option Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/60907b21 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/60907b21 Diff:

[03/50] [abbrv] incubator-beam git commit: Closes #1135

Closes #1135 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d285e85d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d285e85d Diff:

[15/50] [abbrv] incubator-beam git commit: This closes #1158

This closes #1158 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0ec956d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0ec956d3 Diff:

[13/50] [abbrv] incubator-beam git commit: Encode bundle elements in the DirectRunner

Encode bundle elements in the DirectRunner This ensures that any changes that are caused when an element is encoded and decoded is caught within the pipeline. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[31/50] [abbrv] incubator-beam git commit: Closes #1180

Closes #1180 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7091a012 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7091a012 Diff:

[09/50] [abbrv] incubator-beam git commit: Remove pieces of Trigger now owned by TriggerStateMachine

Remove pieces of Trigger now owned by TriggerStateMachine Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1eff320d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1eff320d Diff:

[33/50] [abbrv] incubator-beam git commit: Closes #1105

Closes #1105 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c94b8eac Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c94b8eac Diff:

[37/50] [abbrv] incubator-beam git commit: This closes #1185

This closes #1185 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f30b21a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f30b21a Diff:

[24/50] [abbrv] incubator-beam git commit: Closes #1182

Closes #1182 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f2fe1ae4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f2fe1ae4 Diff:

[04/50] [abbrv] incubator-beam git commit: pom.xml: make Dataflow runner like every other runner

pom.xml: make Dataflow runner like every other runner Pom dependencies no longer require it to be treated specially. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6291a6f6 Tree:

[40/50] [abbrv] incubator-beam git commit: Add default version for beam-sdks-java-io-kafka

Add default version for beam-sdks-java-io-kafka Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c8895338 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c8895338 Diff:

[18/50] [abbrv] incubator-beam git commit: This closes #1163

This closes #1163 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7abdcbfb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7abdcbfb Diff:

[12/50] [abbrv] incubator-beam git commit: Improve teardown behavior in DoFnLifecycleManager

Improve teardown behavior in DoFnLifecycleManager Use Cache invalidation hooks to teardown DoFns that are no longer in the cache. Ensure that remove() and removeAll() report thrown exceptions even though the exceptions are not thrown by the LoadingCache. Project:

[27/50] [abbrv] incubator-beam git commit: [BEAM-809] Create a KryoRegistrator for the SparkRunner.

[BEAM-809] Create a KryoRegistrator for the SparkRunner. Use Class#getName() instead of canonicalName(). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13b83858 Tree:

[19/50] [abbrv] incubator-beam git commit: Remove use of OldDoFn from some DirectRunner tests

Remove use of OldDoFn from some DirectRunner tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3d086857 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3d086857 Diff:

[2/6] incubator-beam git commit: Adding documentation. Setting Python classes as STRING types.

Adding documentation. Setting Python classes as STRING types. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bfcff012 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bfcff012 Diff:

[3/6] incubator-beam git commit: Laying down infrastructure for static display data

Laying down infrastructure for static display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/07885c86 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/07885c86 Diff:

[4/6] incubator-beam git commit: Adding license text to all files. Fixing one lint issue. Refactoring runner_test

Adding license text to all files. Fixing one lint issue. Refactoring runner_test Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11022016 Tree:

[5/6] incubator-beam git commit: Moving files. Using DisplayDataItem to enable dictionaries to be used as display data

Moving files. Using DisplayDataItem to enable dictionaries to be used as display data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d864d968 Tree:

[6/6] incubator-beam git commit: Closes #1112

Closes #1112 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03662da9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/03662da9 Diff:

[1/6] incubator-beam git commit: Addressing comments

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 57f03f793 -> 03662da9d Addressing comments Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1d478dd4 Tree:

[3/3] incubator-beam git commit: Closes #1200

Closes #1200 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ef01140d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ef01140d Diff:

[2/3] incubator-beam git commit: Pushing check down. Rewritting error message

Pushing check down. Rewritting error message Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/32f3214c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/32f3214c Diff:

[1/3] incubator-beam git commit: Improving error of missing sdk_location

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 00b17e542 -> ef01140d6 Improving error of missing sdk_location Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a68c2461 Tree:

[1/2] incubator-beam git commit: Closes #1223

Repository: incubator-beam Updated Branches: refs/heads/python-sdk ef01140d6 -> 03c3c7074 Closes #1223 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03c3c707 Tree:

[GitHub] incubator-beam pull request #1223: Adds IterableCoder, fast coding for sets,...

Github user robertwb closed the pull request at: https://github.com/apache/incubator-beam/pull/1223 --- 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

[2/2] incubator-beam git commit: Adds IterableCoder, fast coding for sets, booleans.

Adds IterableCoder, fast coding for sets, booleans. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9dd16455 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9dd16455 Diff:

[2/3] incubator-beam git commit: Several fixes to coder size estimates.

Several fixes to coder size estimates. The coder returned in alongside the observable must be the coder of the observable's elements, not the coder of the observable itself. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[1/3] incubator-beam git commit: Implement size observation for FastPrimitivesCoderImpl.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 03c3c7074 -> 979e299c7 Implement size observation for FastPrimitivesCoderImpl. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fba0e91b

[3/3] incubator-beam git commit: Closes #1224

Closes #1224 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/979e299c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/979e299c Diff:

[GitHub] incubator-beam pull request #1223: Adds IterableCoder, fast coding for sets,...

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1223 Adds IterableCoder, fast coding for sets, booleans. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] incubator-beam pull request #1224: Estimate sizes

Github user robertwb closed the pull request at: https://github.com/apache/incubator-beam/pull/1224 --- 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

[GitHub] incubator-beam pull request #1211: Compare display data items, not dicts.

Github user robertwb closed the pull request at: https://github.com/apache/incubator-beam/pull/1211 --- 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

[1/2] incubator-beam git commit: Compare display data items, not dicts.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 811858bca -> 00b17e542 Compare display data items, not dicts. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d1cfa1a Tree:

[GitHub] incubator-beam pull request #1253: Optimize WindowedValueCoder

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1253 Optimize WindowedValueCoder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[1/4] incubator-beam git commit: Closes #1007

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 240f8f673 -> eb57b974c Closes #1007 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/46110e4a Tree:

[2/4] incubator-beam git commit: implement codreview feedback

implement codreview feedback Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e223929c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e223929c Diff:

[1/2] incubator-beam git commit: Add profile_memory flag

Repository: incubator-beam Updated Branches: refs/heads/python-sdk ba624e98f -> 240f8f673 Add profile_memory flag Runners with memory profiling support, would use this flag to profile the workflow for heap usage. Renamed the profile flag to profile_cpu flag to make the distinction clear.

[2/2] incubator-beam git commit: Closes #1077

Closes #1077 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/240f8f67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/240f8f67 Diff:

[4/4] incubator-beam git commit: Post-merge fixup.

Post-merge fixup. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb57b974 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb57b974 Diff:

[GitHub] incubator-beam pull request #1100: Windowed side inputs

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1100 Windowed side inputs Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[1/2] incubator-beam git commit: Add license to init files.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk fd27f6848 -> ba624e98f Add license to init files. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ccc01c98 Tree:

[2/2] incubator-beam git commit: Closes #1081

Closes #1081 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ba624e98 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ba624e98 Diff:

[GitHub] incubator-beam pull request #1113: 1053 test

Github user robertwb closed the pull request at: https://github.com/apache/incubator-beam/pull/1113 --- 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

[1/3] incubator-beam git commit: Enhancements and deprecation cleanups related to file compression.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 56ab1a4d5 -> 24b7bcc26 Enhancements and deprecation cleanups related to file compression. - Getting rid of CompressionTypes.ZLIB and CompressionTypes.NO_COMPRESSION. - Introducing BZIP2 compression in analogy to Dataflow

[3/3] incubator-beam git commit: Closes #1053

Closes #1053 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/24b7bcc2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/24b7bcc2 Diff:

[2/2] incubator-beam git commit: Closes #1110

Closes #1110 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/68ddb7ec Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/68ddb7ec Diff:

[1/2] incubator-beam git commit: change required version for oauth2client

Repository: incubator-beam Updated Branches: refs/heads/python-sdk eb57b974c -> 68ddb7ecf change required version for oauth2client Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3727fb81 Tree:

[1/3] incubator-beam git commit: Fixed pip requirement.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 68ddb7ecf -> 56ab1a4d5 Fixed pip requirement. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2b5061a1 Tree:

[2/3] incubator-beam git commit: Added cython version check

Added cython version check Replaced assertions with warnings. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/36ea9b4f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/36ea9b4f Diff:

[3/3] incubator-beam git commit: Closes #1017

Closes #1017 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/56ab1a4d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/56ab1a4d Diff:

[GitHub] incubator-beam pull request #1113: 1053 test

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1113 1053 test Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like: `[BEAM

[1/2] incubator-beam git commit: Add reference to the >> and | operators for pipelines.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 43057960a -> 75be6e974 Add reference to the >> and | operators for pipelines. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3510ff99

[2/2] incubator-beam git commit: Closes #1521

Closes #1521 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/75be6e97 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/75be6e97 Diff:

[2/2] incubator-beam git commit: Closes #1544

Closes #1544 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1392f70b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1392f70b Diff:

[1/2] incubator-beam git commit: Handle empty batches in GcsIO batch methods

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 75be6e974 -> 1392f70b6 Handle empty batches in GcsIO batch methods Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3ef83b33 Tree:

[2/2] incubator-beam git commit: Fix a typo in query split error handling

Fix a typo in query split error handling Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d6afb906 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d6afb906 Diff:

[1/2] incubator-beam git commit: Closes #1542

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 1392f70b6 -> 44c1586f3 Closes #1542 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44c1586f Tree:

[1/2] incubator-beam git commit: Closes #1492

Repository: incubator-beam Updated Branches: refs/heads/python-sdk d5e8c79a3 -> 4a660c604 Closes #1492 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4a660c60 Tree:

[2/2] incubator-beam git commit: Closes #1571

Closes #1571 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f086afe1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f086afe1 Diff:

[1/2] incubator-beam git commit: [BEAM-1124] Temporarily Ignore a ValidatesRunnerTest That Broke Postcommit

Repository: incubator-beam Updated Branches: refs/heads/python-sdk b265dceaa -> f086afe12 [BEAM-1124] Temporarily Ignore a ValidatesRunnerTest That Broke Postcommit Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

<    1   2   3   4   5   >