[03/39] incubator-beam git commit: BEAM-261 Use Apex 3.5.0-SNAPSHOT to use loopback as connect address.

2016-11-11 Thread kenn
BEAM-261 Use Apex 3.5.0-SNAPSHOT to use loopback as connect address. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a7e430d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a7e430d6 Diff:

[39/39] incubator-beam git commit: Merge apex-runner to master. This closes #1305.

2016-11-11 Thread kenn
Merge apex-runner to master. This closes #1305. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7d069a65 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7d069a65 Diff:

[22/39] incubator-beam git commit: Merge branch 'master' into apex-runner

2016-11-11 Thread kenn
Merge branch 'master' into apex-runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6fc47ed1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6fc47ed1 Diff:

[25/39] incubator-beam git commit: Closes #1227

2016-11-11 Thread kenn
Closes #1227 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51af7e59 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/51af7e59 Diff:

[23/39] incubator-beam git commit: Adjust for merge from master.

2016-11-11 Thread kenn
Adjust for merge from 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/968eb32b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/968eb32b Diff:

[16/39] incubator-beam git commit: Closes #1139

2016-11-11 Thread kenn
Closes #1139 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/989e3998 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/989e3998 Diff:

[3/4] incubator-beam git commit: Remove DoFnSignatures.INSTANCE

2016-11-10 Thread kenn
Remove DoFnSignatures.INSTANCE Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/efad9d47 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/efad9d47 Diff:

[1/4] incubator-beam git commit: Remove OnTimerInvokers.INSTANCE; deprecate DoFnInvokers.INSTANCE

2016-11-10 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master f7745dc29 -> 3f8db06bd http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/14a71e43/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java

[2/4] incubator-beam git commit: Remove OnTimerInvokers.INSTANCE; deprecate DoFnInvokers.INSTANCE

2016-11-10 Thread kenn
Remove OnTimerInvokers.INSTANCE; deprecate DoFnInvokers.INSTANCE Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/14a71e43 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/14a71e43 Diff:

[2/4] incubator-beam git commit: Update examples archetype to match examples

2016-11-10 Thread kenn
Update examples archetype to match examples Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1e132ee8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1e132ee8 Diff:

[4/4] incubator-beam git commit: This closes #1338

2016-11-10 Thread kenn
This closes #1338 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/503b4071 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/503b4071 Diff:

[1/4] incubator-beam git commit: fixup! Add script

2016-11-10 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master e43a38355 -> 503b40717 fixup! Add script Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cd5eca8d Tree:

[3/4] incubator-beam git commit: Add script to update examples archetype automatically

2016-11-10 Thread kenn
Add script to update examples archetype automatically Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f78c443 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f78c443 Diff:

[1/6] incubator-beam git commit: This closes #1320

2016-11-10 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master ab06647f9 -> 11eaed19a This closes #1320 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11eaed19 Tree:

[2/6] incubator-beam git commit: Make test timeout configurable and use in TestDataflowRunner

2016-11-10 Thread kenn
Make test timeout configurable and use in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e82e35b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e82e35b Diff:

[6/6] incubator-beam git commit: Make TestDataflowRunner crash message actionable

2016-11-10 Thread kenn
Make TestDataflowRunner crash message actionable Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5653b860 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5653b860 Diff:

[4/6] incubator-beam git commit: Fix null or empty check in TestDataflowRunner

2016-11-10 Thread kenn
Fix null or empty check in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/73449146 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/73449146 Diff:

[3/6] incubator-beam git commit: Fix breakage in WindowedWordCountIT

2016-11-10 Thread kenn
Fix breakage in WindowedWordCountIT Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e5b2f13f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e5b2f13f Diff:

[1/2] incubator-beam git commit: This closes #1318

2016-11-09 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master f802919c2 -> ef750c0f8 This closes #1318 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ef750c0f Tree:

[2/2] incubator-beam git commit: Fix findbugs errors and re-enable for runners-core

2016-11-09 Thread kenn
Fix findbugs errors and re-enable for runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/047911d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/047911d3 Diff:

[4/4] incubator-beam git commit: This closes #1315

2016-11-08 Thread kenn
This closes #1315 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/084a5e8a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/084a5e8a Diff:

[2/4] incubator-beam git commit: Revise WordCount example to be better cross-runner example

2016-11-08 Thread kenn
Revise WordCount example to be better cross-runner example Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0b05a8c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0b05a8c7 Diff:

[1/4] incubator-beam git commit: Hardcode MinimalWordCount to the DirectRunner

2016-11-08 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master e35f571b0 -> 084a5e8ae Hardcode MinimalWordCount to the DirectRunner This makes it easy to immediately run, and removes various non-portable instructions and others that aren't the easiest for a "Getting Started" scenario.

[3/4] incubator-beam git commit: Revise DebuggingWordCount to be more portable

2016-11-08 Thread kenn
Revise DebuggingWordCount to be more portable Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9bc9c3f0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9bc9c3f0 Diff:

[3/3] incubator-beam git commit: Add Spark and Flink runner version to root pom

2016-11-08 Thread kenn
Add Spark and Flink runner version to root pom Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/32b93815 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/32b93815 Diff:

[1/3] incubator-beam git commit: This closes #1314

2016-11-08 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master 09f6aa607 -> e35f571b0 This closes #1314 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e35f571b Tree:

[2/3] incubator-beam git commit: Add runner-specific profiles to the examples pom.xml

2016-11-08 Thread kenn
Add runner-specific profiles to the examples 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/80792848 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/80792848 Diff:

[49/50] incubator-beam git commit: [BEAM-79] update GearpumpPipelineResult

2016-11-07 Thread kenn
[BEAM-79] update GearpumpPipelineResult Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2a96a17f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2a96a17f Diff:

[19/50] incubator-beam git commit: Rename RegexTransform to just Regex

2016-11-07 Thread kenn
Rename RegexTransform to just Regex Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6954abe4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6954abe4 Diff:

[15/50] incubator-beam git commit: move source jar creation into release profile

2016-11-07 Thread kenn
move source jar creation into release profile Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/68f26386 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/68f26386 Diff:

[12/50] incubator-beam git commit: Enable javadoc for all modules by default

2016-11-07 Thread kenn
Enable javadoc for all modules by default Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aae65db6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aae65db6 Diff:

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

2016-11-07 Thread kenn
Merge branch 'master' into gearpump-runner # Conflicts: # runners/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/0c362282 Tree:

[17/50] incubator-beam git commit: Added Regex Transform and test.

2016-11-07 Thread kenn
Added Regex Transform and 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/bc28799d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bc28799d Diff:

[38/50] incubator-beam git commit: Generalize extraction of DoFn parameters from context

2016-11-07 Thread kenn
Generalize extraction of DoFn parameters from context Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/40ff9d40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/40ff9d40 Diff:

[34/50] incubator-beam git commit: This closes #1300

2016-11-07 Thread kenn
This closes #1300 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ac252a7e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ac252a7e Diff:

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

2016-11-07 Thread kenn
Closes #1295 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b5f84735 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b5f84735 Diff:

[42/50] incubator-beam git commit: Track Minimum Element Timestamps within Bundles

2016-11-07 Thread kenn
Track Minimum Element Timestamps within Bundles This allows the Watermark Manager to track pending elements by bundles of elements rather than per-element, which significantly reduces the amount of work done per-element to track watermarks. Project:

[29/50] incubator-beam git commit: [BEAM-929] Fix Findbugs issues in Kinesis

2016-11-07 Thread kenn
[BEAM-929] Fix Findbugs issues in Kinesis * Fix equals and hashcode * Add tests * Remove Serializable from KinesisRecord, as it is in fact coded not serialized Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[05/50] incubator-beam git commit: Closes #1284

2016-11-07 Thread kenn
Closes #1284 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6e1e57b0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6e1e57b0 Diff:

[40/50] incubator-beam git commit: This closes #1282

2016-11-07 Thread kenn
This closes #1282 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9de9ce69 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9de9ce69 Diff:

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

2016-11-07 Thread kenn
This closes #1296 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11024552 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/11024552 Diff:

[13/50] incubator-beam git commit: Fix javadoc throughout Beam

2016-11-07 Thread kenn
Fix javadoc throughout Beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/717b431c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/717b431c Diff:

[32/50] incubator-beam git commit: [BEAM-898] Fix Jenkins Build Failure - IT Options Conflicts

2016-11-07 Thread kenn
[BEAM-898] Fix Jenkins Build Failure - IT Options Conflicts This closes #1301 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/912500f1 Tree:

[10/50] incubator-beam git commit: [BEAM-889] Let Spark handle the user-provided checkpointDir, but warn if not a reliable fs.

2016-11-07 Thread kenn
[BEAM-889] Let Spark handle the user-provided checkpointDir, but warn if not a reliable fs. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/90a75d1f Tree:

[45/50] incubator-beam git commit: [BEAM-917] ExpectedLogs: clear saved records after each test.

2016-11-07 Thread kenn
[BEAM-917] ExpectedLogs: clear saved records after each test. This closes #1289 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/339dee95 Tree:

[28/50] incubator-beam git commit: Closes #1298

2016-11-07 Thread kenn
Closes #1298 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9b47228c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9b47228c Diff:

[08/50] incubator-beam git commit: Remove @Default from IT options

2016-11-07 Thread kenn
Remove @Default from IT options Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1eccd29b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1eccd29b Diff:

[50/50] incubator-beam git commit: This closes #1306

2016-11-07 Thread kenn
This closes #1306 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a14927f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a14927f4 Diff:

[44/50] incubator-beam git commit: [BEAM-917] ExpectedLogs: clear saved records after each test.

2016-11-07 Thread kenn
[BEAM-917] ExpectedLogs: clear saved records after each 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/6bf729e9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6bf729e9 Diff:

[07/50] incubator-beam git commit: Flatten FiredTimers and ExtractFiredTimers

2016-11-07 Thread kenn
Flatten FiredTimers and ExtractFiredTimers Pass a single collection of fired timers, and have those objects contain the associated transform and key that they fired for. Timers already contain the domain they are in. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[36/50] incubator-beam git commit: Add DoFnInvoker dispatch for State and Timer parameters

2016-11-07 Thread kenn
Add DoFnInvoker dispatch for State and Timer parameters Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e2db8268 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e2db8268 Diff:

[16/50] incubator-beam git commit: Closes #1292

2016-11-07 Thread kenn
Closes #1292 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70255d26 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70255d26 Diff:

[02/50] incubator-beam git commit: checkstyle: move from individual modules to root poms

2016-11-07 Thread kenn
checkstyle: move from individual modules to root poms Checkstyle config is no longer needed in individual modules; instead, move it only to sdks/ , runners/, and examples/ poms. Individual modules like sdks/java/core may still reference checkstyle to configure their own options. The only sketchy

[04/50] incubator-beam git commit: pom: move maven-archetypes to its proper spot in dep hierarchy

2016-11-07 Thread kenn
pom: move maven-archetypes to its proper spot in dep hierarchy Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f19a25da Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f19a25da Diff:

[22/50] incubator-beam git commit: Disable all broken findbugs builds and link to JIRA issues

2016-11-07 Thread kenn
Disable all broken findbugs builds and link to JIRA issues Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e1291eea Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e1291eea Diff:

[25/50] incubator-beam git commit: [BEAM-725] Migrate to use the generic credentials library compatible with Apiary and gRPC instead of the Apiary only credentials library.

2016-11-07 Thread kenn
[BEAM-725] Migrate to use the generic credentials library compatible with Apiary and gRPC instead of the Apiary only credentials library. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bb260ecd Tree:

[37/50] incubator-beam git commit: Rename BoundedWindowParameter -> WindowParameter

2016-11-07 Thread kenn
Rename BoundedWindowParameter -> WindowParameter Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/85b908be Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/85b908be Diff:

[23/50] incubator-beam git commit: move findbugs execution to release profile, enable in all modules

2016-11-07 Thread kenn
move findbugs execution to release profile, enable in all modules Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fae52a3f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fae52a3f Diff:

[31/50] incubator-beam git commit: Fix IT Options Conflict

2016-11-07 Thread kenn
Fix IT Options Conflict Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/19279689 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/19279689 Diff:

[06/50] incubator-beam git commit: This closes #1276

2016-11-07 Thread kenn
This closes #1276 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/99062d10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/99062d10 Diff:

[39/50] incubator-beam git commit: Allow BoundedWindow subclasses in DoFn parameter list

2016-11-07 Thread kenn
Allow BoundedWindow subclasses in DoFn parameter list Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9c3e59fa Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9c3e59fa Diff:

[35/50] incubator-beam git commit: Switch DoFnInvokersTest to use a mock ExtraContextFactory

2016-11-07 Thread kenn
Switch DoFnInvokersTest to use a mock ExtraContextFactory Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c052d2a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c052d2a1 Diff:

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

2016-11-07 Thread kenn
This closes #506 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f6a9733f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f6a9733f Diff:

[30/50] incubator-beam git commit: Closes #1299

2016-11-07 Thread kenn
Closes #1299 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3e84a5f3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3e84a5f3 Diff:

[20/50] incubator-beam git commit: Format Regex according to style guidelines

2016-11-07 Thread kenn
Format Regex according to style guidelines Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/79b04551 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/79b04551 Diff:

[33/50] incubator-beam git commit: Update Watermarks even if a Reader is empty

2016-11-07 Thread kenn
Update Watermarks even if a Reader is empty This ensures that the pipeline will make progress even if a reader stops producing elements. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ff7fe07b Tree:

[47/50] incubator-beam git commit: This closes #1303

2016-11-07 Thread kenn
This closes #1303 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/99505e12 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/99505e12 Diff:

[43/50] incubator-beam git commit: This closes #1287

2016-11-07 Thread kenn
This closes #1287 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c6d9bf29 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c6d9bf29 Diff:

[41/50] incubator-beam git commit: Incrementally update Pending elements when work completes

2016-11-07 Thread kenn
Incrementally update Pending elements when work completes This reduces the amount of single-threaded updates the monitor thread performs before firing timers. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

2016-11-07 Thread kenn
This closes #1272 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/14e093a0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/14e093a0 Diff:

[01/50] incubator-beam git commit: This closes #1252

2016-11-07 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/gearpump-runner 323ec1188 -> a14927f40 This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/faf55c78 Tree:

[09/50] incubator-beam git commit: [BEAM-898] Fix Jenkins BigQueryTornadoes IT Failure

2016-11-07 Thread kenn
[BEAM-898] Fix Jenkins BigQueryTornadoes IT Failure This closes #1279 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/46fbfe06 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/46fbfe06 Diff:

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

2016-11-07 Thread kenn
Closes #1285 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f06deac8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f06deac8 Diff:

[27/50] incubator-beam git commit: Sorter: fix README to support syntax highlighting

2016-11-07 Thread kenn
Sorter: fix README to support syntax highlighting Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0604d2bb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0604d2bb Diff:

[26/50] incubator-beam git commit: [BEAM-725] Migrate to use the generic Google credentials library

2016-11-07 Thread kenn
[BEAM-725] Migrate to use the generic Google credentials library This closes #1294 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/baa7fb03 Tree:

[2/2] incubator-beam git commit: Add OnTimerInvoker(s), for invoking DoFn @OnTimer methods

2016-11-07 Thread kenn
Add OnTimerInvoker(s), for invoking DoFn @OnTimer methods OnTimerInvoker encapsulates the dispatch from onTimer() to a call to the DoFn method annotated with @OnTimer(). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[1/2] incubator-beam git commit: This closes #1256

2016-11-07 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master 99505e125 -> afa0c31bd This closes #1256 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/afa0c31b Tree:

[5/6] incubator-beam git commit: Add DoFnInvoker dispatch for State and Timer parameters

2016-11-07 Thread kenn
Add DoFnInvoker dispatch for State and Timer parameters Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e2db8268 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e2db8268 Diff:

[6/6] incubator-beam git commit: This closes #1282

2016-11-07 Thread kenn
This closes #1282 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9de9ce69 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9de9ce69 Diff:

[4/6] incubator-beam git commit: Switch DoFnInvokersTest to use a mock ExtraContextFactory

2016-11-07 Thread kenn
Switch DoFnInvokersTest to use a mock ExtraContextFactory Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c052d2a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c052d2a1 Diff:

[3/6] incubator-beam git commit: Generalize extraction of DoFn parameters from context

2016-11-07 Thread kenn
Generalize extraction of DoFn parameters from context Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/40ff9d40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/40ff9d40 Diff:

[2/6] incubator-beam git commit: Rename BoundedWindowParameter -> WindowParameter

2016-11-07 Thread kenn
Rename BoundedWindowParameter -> WindowParameter Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/85b908be Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/85b908be Diff:

[1/6] incubator-beam git commit: Allow BoundedWindow subclasses in DoFn parameter list

2016-11-07 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master ac252a7e1 -> 9de9ce69f Allow BoundedWindow subclasses in DoFn parameter list Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9c3e59fa Tree:

[1/3] incubator-beam git commit: Rename RegexTransform to just Regex

2016-11-07 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master f6a9733f5 -> 110245526 Rename RegexTransform to just Regex Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6954abe4 Tree:

[3/3] incubator-beam git commit: This closes #1296

2016-11-07 Thread kenn
This closes #1296 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11024552 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/11024552 Diff:

[2/3] incubator-beam git commit: Format Regex according to style guidelines

2016-11-07 Thread kenn
Format Regex according to style guidelines Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/79b04551 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/79b04551 Diff:

[2/2] incubator-beam git commit: This closes #1265

2016-11-03 Thread kenn
This closes #1265 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2a1fdee5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2a1fdee5 Diff:

[1/2] incubator-beam git commit: Move the separate package-info.java compile to java7 profile since it's not needed with java8 This fixes compiling in Eclipse (assuming Neon which require java8) Sligh

2016-11-03 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master eac68cb21 -> 2a1fdee5c Move the separate package-info.java compile to java7 profile since it's not needed with java8 This fixes compiling in Eclipse (assuming Neon which require java8) Slightly speeds up Java8 compile (one invoke

[1/2] incubator-beam git commit: [BEAM-79] Port Gearpump runner from OldDoFn to new DoFn

2016-11-03 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/gearpump-runner 3933b5577 -> 323ec1188 [BEAM-79] Port Gearpump runner from OldDoFn to new DoFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: This closes #1234

2016-11-03 Thread kenn
This closes #1234 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/323ec118 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/323ec118 Diff:

[3/3] incubator-beam git commit: This closes #968

2016-11-01 Thread kenn
This closes #968 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e0cfe5b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e0cfe5b Diff:

[1/3] incubator-beam git commit: Added a where method on TypeDescriptor to allow substituting a type parameter with a TypeDescriptor. In the process introduced a TypeParameter class which represents t

2016-11-01 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master f6ad58d60 -> 7e0cfe5b9 Added a where method on TypeDescriptor to allow substituting a type parameter with a TypeDescriptor. In the process introduced a TypeParameter class which represents the parameter type. This is useful when

[2/3] incubator-beam git commit: Add header

2016-11-01 Thread kenn
Add header Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a36f1fa8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a36f1fa8 Diff:

[1/3] incubator-beam git commit: Delete the obsolete ExecutableTrigger

2016-10-31 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master af1764785 -> 978c99e9d Delete the obsolete ExecutableTrigger Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1abe47bb Tree:

[3/3] incubator-beam git commit: This closes #1187

2016-10-31 Thread kenn
This closes #1187 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/978c99e9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/978c99e9 Diff:

[2/3] incubator-beam git commit: Update Dataflow worker image

2016-10-31 Thread kenn
Update Dataflow worker image Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/97cd3e5c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/97cd3e5c Diff:

[1/2] incubator-beam git commit: Add static factory methods for DoFnInfo

2016-10-31 Thread kenn
Repository: incubator-beam Updated Branches: refs/heads/master 7e4583027 -> af1764785 Add static factory methods for DoFnInfo This provides a clearer migration path away from deprecated code paths than constructor overloads which can only be selected by upcasting, etc. Project:

[2/2] incubator-beam git commit: This closes #1215

2016-10-31 Thread kenn
This closes #1215 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/af176478 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/af176478 Diff:

[3/3] incubator-beam git commit: This closes #1226

2016-10-31 Thread kenn
This closes #1226 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d8eb8be1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d8eb8be1 Diff:

[2/3] incubator-beam git commit: Fixes a compile error in SourceRDD

2016-10-31 Thread kenn
Fixes a compile error in SourceRDD Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63cbb974 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/63cbb974 Diff:

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