[36/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/beam into sync-master

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f1582570 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f1582570 Diff:

[09/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

[BEAM-79] Fix gearpump-runner merge conflicts and test failure Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3eab6a64 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3eab6a64 Diff:

[42/50] [abbrv] beam git commit: Revert accidental changes to sdks/java/pom.xml

Revert accidental changes to sdks/java/pom.xml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e655f53c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e655f53c Diff:

[16/50] [abbrv] beam git commit: Update gearpump-runner against master changes.

Update gearpump-runner against master changes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/44d21ac6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/44d21ac6 Diff:

[40/50] [abbrv] beam git commit: Fix ParDoTest#testPipelineOptionsParameter

Fix ParDoTest#testPipelineOptionsParameter Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/725f547f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/725f547f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/725f547f

[23/50] [abbrv] beam git commit: This closes #3172: Sync gearpump-runner with master

This closes #3172: Sync gearpump-runner with master Update gearpump-runner against master changes Use stable naming strategy for ByteBuddy invokers Translate a Pipeline in SdkComponents [TRIVIAL] runners-core: delete placeholder Fixes an accidentally found bug in SimpleDoFnRunner

[32/50] [abbrv] beam git commit: Fix PCollectionView translation

Fix PCollectionView translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a7b5d981 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a7b5d981 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a7b5d981 Branch:

[35/50] [abbrv] beam git commit: This closes #3388: Sync gearpump-runner branch with master

This closes #3388: Sync gearpump-runner branch with master Remove unused codes Fix kryo exception Fix PCollectionView translation upgrade to gearpump 0.8.4-SNAPSHOT Fix side input handling in DoFnFunction Respect WindowFn#getOutputTime in gearpump-runner Activate Gearpump

[33/50] [abbrv] beam git commit: Fix kryo exception

Fix kryo exception Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11caa978 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11caa978 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/11caa978 Branch:

[22/50] [abbrv] beam git commit: Update gearpump-runner against master changes

Update gearpump-runner against master changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c06967c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6c06967c Diff:

[21/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/beam into sync-master

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bc8da292 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bc8da292 Diff:

[12/50] [abbrv] beam git commit: This closes #2302: Add unit tests to Gearpump runner

This closes #2302: Add unit tests to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4f23330 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4f23330 Diff:

[43/50] [abbrv] beam git commit: Upgrade BEAM version to 2.2.0-SNAPSHOT in gearpump-runner

Upgrade BEAM version to 2.2.0-SNAPSHOT in gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/daa75669 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/daa75669 Diff:

[26/50] [abbrv] beam git commit: Activate Gearpump local-validates-runner-tests in precommit

Activate Gearpump local-validates-runner-tests in precommit Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c7e3e6a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3c7e3e6a Diff:

[46/50] [abbrv] beam git commit: Require java 8 for precommit tests and add gearpump-runner

Require java 8 for precommit tests and add gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a282165c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a282165c Diff:

[41/50] [abbrv] beam git commit: This closes #3515: Sync gearpump-runner with master and upgrade to gearpump 0.8.4

This closes #3515: Sync gearpump-runner with master and upgrade to gearpump 0.8.4 Fix ParDoTest#testPipelineOptionsParameter Upgrade to gearpump 0.8.4 Fix javadoc generation for AmqpIO, CassandraIO and HCatalogIO Simplified ByteBuddyOnTimerInvokerFactory Fix bad merge Made

[29/50] [abbrv] beam git commit: This closes #3292: Merge master into gearpump-runner

This closes #3292: Merge master into gearpump-runner Adjustments to gearpump-runner: Fix side input handling in DoFnFunction Respect WindowFn#getOutputTime in gearpump-runner Activate Gearpump local-validates-runner-tests in precommit Update against master changes Merged from master:

[04/50] [abbrv] beam git commit: [BEAM-79] Add SideInput support for GearpumpRunner

[BEAM-79] Add SideInput support for GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4eb50d15 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4eb50d15 Diff:

[38/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/beam into sync-master

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c2d3fbc3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c2d3fbc3 Diff:

[08/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

http://git-wip-us.apache.org/repos/asf/beam/blob/3eab6a64/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/WindowBoundTranslator.java -- diff --git

[27/50] [abbrv] beam git commit: Respect WindowFn#getOutputTime in gearpump-runner

Respect WindowFn#getOutputTime in gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/98854d4d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/98854d4d Diff:

[15/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner # Conflicts: # .test-infra/jenkins/job_beam_PostCommit_Java_ValidatesRunner_Gearpump.groovy # runners/pom.xml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[18/50] [abbrv] beam git commit: Merge remote-tracking branch 'upstream/master' into gearpump-runner

Merge remote-tracking branch 'upstream/master' into gearpump-runner # Conflicts: # .travis.yml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9a59ea32 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9a59ea32

[25/50] [abbrv] beam git commit: Update against master changes

Update against master changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c9aac967 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c9aac967 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c9aac967 Branch:

[20/50] [abbrv] beam git commit: This closes #2888: Merge master into gearpump-runner branch

This closes #2888: Merge master into gearpump-runner branch Update gearpump-runner against master changes Introduces read/writePubsubMessages Removed coder and formatFn from PubsubIO.Write Removed coder and parseFn from PubsubIO.Read Add Additional CloudObjectTranslators Updating

[01/50] [abbrv] beam git commit: [BEAM-79] Support merging windows in GearpumpRunner

Repository: beam Updated Branches: refs/heads/master c9abd15e5 -> 89236e3b5 [BEAM-79] Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7af64720 Tree:

[50/50] [abbrv] beam git commit: This closes #3636: Merge GearpumpRunner to master branch

This closes #3636: Merge GearpumpRunner to master branch Remove gearpump-runner in precommit tests Override maven-enforcer-plugin for precommit tests Require java 8 for precommit tests and add gearpump-runner Deactivate integration-tests for gearpump-runner by default Add

[19/50] [abbrv] beam git commit: Update gearpump-runner against master changes

Update gearpump-runner against master changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12b9719e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/12b9719e Diff:

[30/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/beam into sync-master

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fed98c84 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fed98c84 Diff:

[11/50] [abbrv] beam git commit: [BEAM-972] Add unit tests to Gearpump runner

[BEAM-972] Add unit tests to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb0d333d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eb0d333d Diff:

[48/50] [abbrv] beam git commit: Remove gearpump-runner in precommit tests

Remove gearpump-runner in precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf154835 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf154835 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bf154835

[28/50] [abbrv] beam git commit: Fix side input handling in DoFnFunction

Fix side input handling in DoFnFunction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7653e7ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7653e7ed Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7653e7ed

[37/50] [abbrv] beam git commit: This closes #3479: [BEAM-79] Merge master into gearpump-runner branch

This closes #3479: [BEAM-79] Merge master into gearpump-runner branch Don't call .testingPipelineOptions() a second time GCP IO ITs now all use --project option Select SDK distribution based on the selected SDK name [BEAM-2373] Upgrade commons-compress dependency version to 1.14 Define

[44/50] [abbrv] beam git commit: Add beam-runners-gearpump dependency to javadoc

Add beam-runners-gearpump dependency to javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/49d4ed59 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/49d4ed59 Diff:

[47/50] [abbrv] beam git commit: Override maven-enforcer-plugin for precommit tests

Override maven-enforcer-plugin for precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/18daed90 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/18daed90 Diff:

[13/50] [abbrv] beam git commit: [BEAM-972] Add more unit test to Gearpump runner

[BEAM-972] Add more unit test to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3138dde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3138dde Diff:

[14/50] [abbrv] beam git commit: This closes #2521: Add more unit test to Gearpump runner

This closes #2521: Add more unit test to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ebbb6139 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ebbb6139 Diff:

[34/50] [abbrv] beam git commit: Remove unused codes

Remove unused codes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b21fa04f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b21fa04f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b21fa04f Branch:

[07/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f917987 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f917987 Diff:

[10/50] [abbrv] beam git commit: This closes #2241: merge master to gearpump-master and fixup

This closes #2241: merge master to gearpump-master and fixup [BEAM-79] Fix gearpump-runner merge conflicts and test failure Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources' [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline

[17/50] [abbrv] beam git commit: This closes #2610: Merge master into gearpump-runner branch

This closes #2610: Merge master into gearpump-runner branch Update gearpump-runner against master changes. add temp dataset location for non-query BigQuerySource added module option, use more common zero test, show module name in log Modify types for input PCollections of Flatten

[02/50] [abbrv] beam git commit: This closes #1935: Support merging windows in GearpumpRunner

This closes #1935: Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d0aed92 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d0aed92 Diff:

[31/50] [abbrv] beam git commit: upgrade to gearpump 0.8.4-SNAPSHOT

upgrade to gearpump 0.8.4-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f61822d4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f61822d4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f61822d4

[06/50] [abbrv] beam git commit: This closes #2150: Add SideInput support for GearpumpRunner

This closes #2150: Add SideInput support for GearpumpRunner enable ParDoTest [BEAM-79] Add SideInput support for GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15a8ad62 Tree:

[45/50] [abbrv] beam git commit: Deactivate integration-tests for gearpump-runner by default

Deactivate integration-tests for gearpump-runner by default Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d9bb4cb6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d9bb4cb6 Diff:

[24/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/beam into sync-master

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9e6c9061 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9e6c9061 Diff:

[03/50] [abbrv] beam git commit: [BEAM-79] Add SideInput support for GearpumpRunner

http://git-wip-us.apache.org/repos/asf/beam/blob/4eb50d15/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/utils/TranslatorUtils.java -- diff --git

[05/50] [abbrv] beam git commit: enable ParDoTest

enable ParDoTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3dc8fc81 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3dc8fc81 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3dc8fc81 Branch:

beam git commit: Fix compile break

Repository: beam Updated Branches: refs/heads/master 89236e3b5 -> 2fa4fdecd Fix compile break Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2fa4fdec Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2fa4fdec Diff:

[1/2] beam git commit: Use LinkedHashMap for step contexts in BaseExecutionContext

Repository: beam Updated Branches: refs/heads/master 1b0400fee -> f33039bfd Use LinkedHashMap for step contexts in BaseExecutionContext This gives a performance improvement when all step contexts need to be traversed, such as for state cleanup operations. Project:

[2/2] beam git commit: This closes #2653 Add comments to Trigger.java

This closes #2653 Add comments to Trigger.java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eec903fb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eec903fb Diff:

[1/2] beam git commit: Add comments to Trigger.java

Repository: beam Updated Branches: refs/heads/master 4c3174b80 -> eec903fb5 Add comments to Trigger.java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c15fe056 Tree:

[2/2] beam git commit: This closes #2830: Add an @Internal Annotation

This closes #2830: Add an @Internal Annotation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9114eb3e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9114eb3e Diff:

[5/6] beam git commit: Simplify type parameters of StateSpec and related

Simplify type parameters of StateSpec and related Before this change, almost all uses of state had a type variable that existing only to support the esoteric use of a KeyedCombineFn in a state cell. KeyedCombineFn is now gone, so the key is no longer required. Project:

[2/6] beam git commit: Simplify type parameters of StateSpec and related

http://git-wip-us.apache.org/repos/asf/beam/blob/8fe59c35/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java

[3/6] beam git commit: Simplify type parameters of StateSpec and related

http://git-wip-us.apache.org/repos/asf/beam/blob/8fe59c35/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java -- diff --git

[6/6] beam git commit: This closes #2627: Remove extraneous type variable from StateSpec

This closes #2627: Remove extraneous type variable from StateSpec Make DoFnSignatures robust to StateSpec subclasses Simplify type parameters of StateSpec and related Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[4/6] beam git commit: Simplify type parameters of StateSpec and related

http://git-wip-us.apache.org/repos/asf/beam/blob/8fe59c35/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java -- diff --git

[2/2] beam git commit: This closes #2826: Use processing time for synchronized processing time in Flink runner

This closes #2826: Use processing time for synchronized processing time in Flink runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c2c89eda Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c2c89eda Diff:

[1/2] beam git commit: Use processing time for synchronized processing time in Flink runner

Repository: beam Updated Branches: refs/heads/master b40b26501 -> c2c89eda9 Use processing time for synchronized processing time in Flink runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/05722acc Tree:

[4/4] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/d7f46849 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/d7f46849 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/d7f46849

[3/4] beam-site git commit: Minor touch-ups to Gearpump listing on overview

Minor touch-ups to Gearpump listing on overview - Alphabetical order - Add a space Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/da7d6c0e Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/da7d6c0e Diff:

[2/4] beam-site git commit: This closes #223: Add a gearpump runner web page

This closes #223: Add a gearpump runner web page Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/94f50512 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/94f50512 Diff:

[1/2] beam git commit: Remove job name usages from BigQueryIO at pipeline construction time

Repository: beam Updated Branches: refs/heads/master 57f449c4c -> 17f0843eb Remove job name usages from BigQueryIO at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0ddf8d49 Tree:

[2/2] beam git commit: This closes #2846: BigQueryIO: Remove PipelineOptions.getJobName usages at pipeline construction time

This closes #2846: BigQueryIO: Remove PipelineOptions.getJobName usages at pipeline construction time Remove job name usages from BigQueryIO at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: BigQueryIO: Remove tempLocation usage at pipeline construction time

Repository: beam Updated Branches: refs/heads/master ad12f6316 -> f3f881084 BigQueryIO: Remove tempLocation usage at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d0a2249f Tree:

[2/2] beam git commit: This closes #2873: BigQueryIO: Remove tempLocation usage at pipeline construction time

This closes #2873: BigQueryIO: Remove tempLocation usage at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3f88108 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3f88108 Diff:

[1/2] beam git commit: Inline TypedPValue

Repository: beam Updated Branches: refs/heads/master 34d25f406 -> ff6bb3530 Inline TypedPValue This has exactly one implementation, and this is not expected to change. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2867: Inline TypedPValue

This closes #2867: Inline TypedPValue Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ff6bb353 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ff6bb353 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ff6bb353

[1/2] beam git commit: Correct javadoc for mobile gaming examples

Repository: beam Updated Branches: refs/heads/master c6ac3eca0 -> 03a7f92e3 Correct javadoc for mobile gaming examples Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/968a59f7 Tree:

[2/2] beam git commit: This closes #3068: Correct javadoc for mobile gaming examples

This closes #3068: Correct javadoc for mobile gaming examples Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/03a7f92e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/03a7f92e Diff:

[2/2] beam git commit: This closes #3071: bump time of precommits

This closes #3071: bump time of precommits Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/62ee2754 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/62ee2754 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/62ee2754

[1/2] beam git commit: bump time of precommits

Repository: beam Updated Branches: refs/heads/master a39960b13 -> 62ee27542 bump time of precommits Signed-off-by: Jason Kuster Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/416b89b7 Tree:

[1/2] beam git commit: Correct javadoc for mobile gaming examples

Repository: beam Updated Branches: refs/heads/release-2.0.0 24914cbf2 -> e08cac055 Correct javadoc for mobile gaming examples Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9fdd2e03 Tree:

[2/2] beam git commit: This closes #3069: Cherrypick #3068, updating mobile gaming javadoc, to release-2.0.0

This closes #3069: Cherrypick #3068, updating mobile gaming javadoc, to release-2.0.0 Correct javadoc for mobile gaming examples Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e08cac05 Tree:

[2/2] beam git commit: This closes #3063: Fix a typo in TestDataflowRunnerTest

This closes #3063: Fix a typo in TestDataflowRunnerTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8994afa5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8994afa5 Diff:

[1/2] beam git commit: Fix a typo in TestDataflowRunnerTest

Repository: beam Updated Branches: refs/heads/master d32213bfc -> 8994afa51 Fix a typo in TestDataflowRunnerTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22d87785 Tree:

[1/2] beam git commit: Remove Timer.cancel() from user-facing API

Repository: beam Updated Branches: refs/heads/master b1382969b -> 6dc39cd35 Remove Timer.cancel() from user-facing API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c755921f Tree:

[2/2] beam git commit: This closes #3035: Remove Timer.cancel() from user-facing API

This closes #3035: Remove Timer.cancel() from user-facing API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6dc39cd3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6dc39cd3 Diff:

[3/4] beam git commit: Move TestDataflowRunner into dataflow package

Move TestDataflowRunner into dataflow package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d305d6d3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d305d6d3 Diff:

[1/4] beam git commit: Register the TestDataflowRunner via registrar

Repository: beam Updated Branches: refs/heads/release-2.0.0 61c5a42f8 -> 9f7521f8d Register the TestDataflowRunner via registrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a71f6cd4 Tree:

[2/4] beam git commit: Move TestDataflowRunner into dataflow package

http://git-wip-us.apache.org/repos/asf/beam/blob/d305d6d3/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/testing/TestDataflowRunnerTest.java -- diff --git

[4/4] beam git commit: This closes #2944: Cherry pick #2940 onto release-2.0.0

This closes #2944: Cherry pick #2940 onto release-2.0.0 Move TestDataflowRunner into dataflow package Register the TestDataflowRunner via registrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9f7521f8 Tree:

[1/2] beam git commit: Revise javadoc for sdk, state, options, annotations, window, (and misc)

Repository: beam Updated Branches: refs/heads/release-2.0.0 46fa490a5 -> aa8c9d10f Revise javadoc for sdk, state, options, annotations, window, (and misc) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4950e328 Tree:

[2/2] beam git commit: This closes #3015: Cherry-pick #2987: javadoc improvements

This closes #3015: Cherry-pick #2987: javadoc improvements Revise javadoc for sdk, state, options, annotations, window, (and misc) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa8c9d10 Tree:

[1/2] beam git commit: Revise javadoc for sdk, state, options, annotations, window, (and misc)

Repository: beam Updated Branches: refs/heads/master a5e6a0f12 -> b44e99b09 Revise javadoc for sdk, state, options, annotations, window, (and misc) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/849f1225 Tree:

[2/2] beam git commit: This closes #2987: Revise javadoc for sdk, state, options, annotations, window, (and misc)

This closes #2987: Revise javadoc for sdk, state, options, annotations, window, (and misc) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b44e99b0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b44e99b0 Diff:

[2/2] beam git commit: Thsi closes #3047: Cherry-pick #3035, removing Timer.cancel(), to release-2.0.0

Thsi closes #3047: Cherry-pick #3035, removing Timer.cancel(), to release-2.0.0 Remove Timer.cancel() from user-facing API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/60fc4dc3 Tree:

[1/2] beam git commit: Remove Timer.cancel() from user-facing API

Repository: beam Updated Branches: refs/heads/release-2.0.0 ad08a0bf8 -> 60fc4dc37 Remove Timer.cancel() from user-facing API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c91ba384 Tree:

[2/2] beam git commit: This closes #3151: Use stable naming strategy for ByteBuddy invokers

This closes #3151: Use stable naming strategy for ByteBuddy invokers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e3c5c65 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5e3c5c65 Diff:

[1/2] beam git commit: Use stable naming strategy for ByteBuddy invokers

Repository: beam Updated Branches: refs/heads/master 467e68f93 -> 5e3c5c657 Use stable naming strategy for ByteBuddy invokers This helps to coalesce related failures across multiple JVM instances, over time, across machines, etc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[4/4] beam git commit: This closes #2988: Fix TestDataflowRunner, PAssertTest, UsesTimersInParDo

This closes #2988: Fix TestDataflowRunner, PAssertTest, UsesTimersInParDo Re-enable UsesTimersInParDo tests in Dataflow runner TestDataflowRunner: throw AssertionError only when assertion known failed Allow any throwable in PAssert to constitute adequate failure Project:

[3/4] beam git commit: Allow any throwable in PAssert to constitute adequate failure

Allow any throwable in PAssert to constitute adequate failure Currently, some PAssert tests require an AssertionError to be thrown. This succeeds on all runners only because many gratuitously throw AssertionError when they don't actually know that an assertion has failed. The spec is just that a

[2/4] beam git commit: TestDataflowRunner: throw AssertionError only when assertion known failed

TestDataflowRunner: throw AssertionError only when assertion known failed It is quite confusing to receive an assertion error when in fact the pipeline has crashed because of user error interacting with e.g. timers. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/4] beam git commit: Re-enable UsesTimersInParDo tests in Dataflow runner

Repository: beam Updated Branches: refs/heads/master 16e4c747c -> d32213bfc Re-enable UsesTimersInParDo tests in Dataflow runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b79c888b Tree:

[2/2] beam git commit: This closes #3337: Include Additional PTransform Inputs in Transform Nodes

This closes #3337: Include Additional PTransform Inputs in Transform Nodes Roll-forward Include Additional PTransform inputs in Transform Nodes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b4c77167 Tree:

[1/2] beam git commit: Roll-forward Include Additional PTransform inputs in Transform Nodes

Repository: beam Updated Branches: refs/heads/master 33883ed88 -> b4c77167f Roll-forward Include Additional PTransform inputs in Transform Nodes Update DirectGraph to have All and Non-Additional Inputs This reverts commit 247f9bc1581984d026764b3d433cb594e700bc21 Project:

[34/50] [abbrv] beam git commit: [BEAM-2410] Remove TransportClient from ElasticSearchIO to decouple IO and ES server versions

[BEAM-2410] Remove TransportClient from ElasticSearchIO to decouple IO and ES server versions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7caea7a8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7caea7a8 Diff:

[14/50] [abbrv] beam git commit: This closes #3303

This closes #3303 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e066a9d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e066a9d6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e066a9d6 Branch:

[49/50] [abbrv] beam git commit: Fix side input handling in DoFnFunction

Fix side input handling in DoFnFunction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7653e7ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7653e7ed Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7653e7ed

<    2   3   4   5   6   7   8   9   10   11   >