[2/2] beam git commit: This closes #3413: Turn notifications for broken Windows test off.

2017-06-21 Thread kenn
This closes #3413: Turn notifications for broken Windows test off. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d25b684 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d25b684 Diff:

[1/2] beam git commit: Turn notifications for broken Windows test off.

2017-06-21 Thread kenn
Repository: beam Updated Branches: refs/heads/master d1d78121b -> 2d25b6840 Turn notifications for broken Windows test off. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/65a6d662 Tree:

[1/2] beam git commit: Add TransformPayloadTranslatorRegistrar

2017-05-19 Thread kenn
Repository: beam Updated Branches: refs/heads/master d7a4e4943 -> 6a68e656a Add TransformPayloadTranslatorRegistrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4a639702 Tree:

[2/2] beam git commit: This closes #3192: Add TransformPayloadTranslatorRegistrar

2017-05-19 Thread kenn
This closes #3192: Add TransformPayloadTranslatorRegistrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6a68e656 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6a68e656 Diff:

[2/2] beam git commit: This closes #3185: Move snappy-java version to dependencyManagement

2017-05-22 Thread kenn
This closes #3185: Move snappy-java version to dependencyManagement Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b68f46cb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b68f46cb Diff:

[1/3] beam git commit: update JavaDoc for BoundedWindow

2017-05-22 Thread kenn
Repository: beam Updated Branches: refs/heads/master b68f46cb8 -> e83fcece5 update JavaDoc for BoundedWindow update JavaDoc rephrase JavaDoc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/de0fdbc1 Tree:

[3/3] beam git commit: This closes #2784: update JavaDoc for BoundedWindow

2017-05-22 Thread kenn
This closes #2784: update JavaDoc for BoundedWindow Minor touch-ups to new BoundedWindow javadoc update JavaDoc for BoundedWindow Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e83fcece Tree:

[2/3] beam git commit: Minor touch-ups to new BoundedWindow javadoc

2017-05-22 Thread kenn
Minor touch-ups to new BoundedWindow javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/143334ca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/143334ca Diff:

[2/2] beam git commit: This closes #3187: Remove Pipeline reference from TransformHierarchy

2017-05-22 Thread kenn
This closes #3187: Remove Pipeline reference from TransformHierarchy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b633abe2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b633abe2 Diff:

[1/2] beam git commit: Remove Pipeline reference from TransformHierarchy

2017-05-22 Thread kenn
Repository: beam Updated Branches: refs/heads/master 983a44926 -> b633abe2c Remove Pipeline reference from TransformHierarchy This change removes a direct dependency cycle between Pipeline and TransformHierarchy. There is still an indirect cycle through PValues, but that is slightly less

[07/16] beam git commit: Move BaseStepContext to the top level

2017-05-23 Thread kenn
Move BaseStepContext to the top level Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59322d51 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59322d51 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/59322d51

[03/16] beam git commit: Remove unused StepContext name methods

2017-05-23 Thread kenn
Remove unused StepContext name methods Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/acce24ce Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/acce24ce Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/acce24ce

[08/16] beam git commit: Implement StepContext directly in the DirectRunner

2017-05-23 Thread kenn
Implement StepContext directly in the DirectRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5ac24e0a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5ac24e0a Diff:

[11/16] beam git commit: Inline and delete BaseExecutionContext

2017-05-23 Thread kenn
Inline and delete BaseExecutionContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0be3cf34 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0be3cf34 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0be3cf34

[01/16] beam git commit: Move StepContext to top level

2017-05-23 Thread kenn
Repository: beam Updated Branches: refs/heads/master 474345f59 -> c84d3da38 Move StepContext to top level Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/98a75551 Tree:

[14/16] beam git commit: Revise StepContext javadoc

2017-05-23 Thread kenn
Revise StepContext javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d425b279 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d425b279 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d425b279 Branch:

[15/16] beam git commit: Remove unused pieces of DirectStepContext

2017-05-23 Thread kenn
Remove unused pieces of DirectStepContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b32a1c35 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b32a1c35 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b32a1c35

[09/16] beam git commit: Shorten excessive name in DirectExecutionContext

2017-05-23 Thread kenn
Shorten excessive name in DirectExecutionContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0dc0334a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0dc0334a Diff:

[04/16] beam git commit: Remove StepContext.noteOutput

2017-05-23 Thread kenn
Remove StepContext.noteOutput Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bed1c53f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bed1c53f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bed1c53f Branch:

[16/16] beam git commit: This closes #3203: Eliminate ExecutionContext and strip down StepContext to what we actually need

2017-05-23 Thread kenn
This closes #3203: Eliminate ExecutionContext and strip down StepContext to what we actually need Remove unused pieces of DirectStepContext Revise StepContext javadoc Shorten excessive name in DirectExecutionContext Delete unused BaseStepContext Delete unused remnants in

[10/16] beam git commit: Remove writePCollectionViewData from the Beam codebase

2017-05-23 Thread kenn
Remove writePCollectionViewData from the Beam codebase Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/32c6cb16 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/32c6cb16 Diff:

[13/16] beam git commit: Delete unused BaseStepContext

2017-05-23 Thread kenn
Delete unused BaseStepContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/62115b29 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/62115b29 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/62115b29 Branch:

[06/16] beam git commit: Remove extraneous ExecutionContext parameter to BaseStepContext

2017-05-23 Thread kenn
Remove extraneous ExecutionContext parameter to BaseStepContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/248c808a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/248c808a Diff:

[02/16] beam git commit: Delete unused remnants in DirectExecutionContext

2017-05-23 Thread kenn
Delete unused remnants in DirectExecutionContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dc585510 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dc585510 Diff:

[1/2] beam git commit: Adds large key tests to GroupByKeyTest

2017-05-24 Thread kenn
Repository: beam Updated Branches: refs/heads/master 6dd5585b3 -> 6418bcfcb Adds large key tests to GroupByKeyTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6a792f32 Tree:

[2/2] beam git commit: This closes #3163: [BEAM-163] Warn the user when a PCollection (via Window.into) has smaller allowe...

2017-05-24 Thread kenn
This closes #3163: [BEAM-163] Warn the user when a PCollection (via Window.into) has smaller allowe... Do not ever shrink allowed lateness Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6dd5585b Tree:

[1/2] beam git commit: Do not ever shrink allowed lateness

2017-05-24 Thread kenn
Repository: beam Updated Branches: refs/heads/master 924dd6335 -> 6dd5585b3 Do not ever shrink allowed lateness This does not seem to have any use except to cause data loss. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2979: Adds large key tests to GroupByKeyTest

2017-05-24 Thread kenn
This closes #2979: Adds large key tests to GroupByKeyTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6418bcfc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6418bcfc Diff:

[1/7] beam git commit: Make Java serialized CombineFn URN public

2017-05-26 Thread kenn
Repository: beam Updated Branches: refs/heads/master 6bb204f34 -> c687887d2 Make Java serialized CombineFn URN public Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a250ce58 Tree:

[3/7] beam git commit: Mark CombineFnWithContext StateSpecs internal

2017-05-26 Thread kenn
Mark CombineFnWithContext StateSpecs internal Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c8478fe1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c8478fe1 Diff:

[6/7] beam git commit: Implement TimerSpec and StateSpec translation

2017-05-26 Thread kenn
Implement TimerSpec and StateSpec translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39220dbc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39220dbc Diff:

[4/7] beam git commit: Add case dispatch to StateSpec

2017-05-26 Thread kenn
Add case dispatch to StateSpec This is different than a StateBinder: for a binder, the id is needed and the StateSpec controls the return type. For case dispatch, the dispatcher controls the type and it should just be reading the spec, which does not require the id. Eventually, StateBinder could

[2/7] beam git commit: Allow translation to throw IOException

2017-05-26 Thread kenn
Allow translation to throw IOException Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b0dc523c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b0dc523c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b0dc523c

[5/7] beam git commit: Flesh out TimerSpec and StateSpec in Runner API

2017-05-26 Thread kenn
Flesh out TimerSpec and StateSpec in Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9497e5ea Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9497e5ea Diff:

[7/7] beam git commit: This closes #3233: [BEAM-115] Runner API Translations for StateSpec and TimerSpec

2017-05-26 Thread kenn
This closes #3233: [BEAM-115] Runner API Translations for StateSpec and TimerSpec Implement TimerSpec and StateSpec translation Make Java serialized CombineFn URN public Add case dispatch to StateSpec Flesh out TimerSpec and StateSpec in Runner API Allow translation to throw

[1/2] beam git commit: Add CombineTranslation

2017-05-25 Thread kenn
Repository: beam Updated Branches: refs/heads/master 1be6f67aa -> 2040e2bd4 Add CombineTranslation This translates Combines to CombinePayloads and back Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b899a85 Tree:

[2/2] beam git commit: This closes #3199: Add CombineTranslation

2017-05-25 Thread kenn
This closes #3199: Add CombineTranslation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2040e2bd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2040e2bd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2040e2bd

beam git commit: Fixup CombineTranslation

2017-05-25 Thread kenn
Repository: beam Updated Branches: refs/heads/master 2040e2bd4 -> 73305d631 Fixup CombineTranslation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/73305d63 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/73305d63

[02/12] beam git commit: Make SdkComponents public for TransformPayloadTranslator

2017-05-25 Thread kenn
Make SdkComponents public for TransformPayloadTranslator Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/26c93681 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/26c93681 Diff:

[03/12] beam git commit: Centralize primitive URNs in PTransformTranslation class

2017-05-25 Thread kenn
Centralize primitive URNs in PTransformTranslation class Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1dc134cf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1dc134cf Diff:

[10/12] beam git commit: URNs for DirectRunner TransformEvaluator and RootInputProvider

2017-05-25 Thread kenn
URNs for DirectRunner TransformEvaluator and RootInputProvider This makes two of the Java DirectRunner's registries key off URN instead of Java class. A root TransformEvaluator requires shards generated by its associated RootInputProvider, hence changing both at once. Project:

[05/12] beam git commit: Register ReadTranslator

2017-05-25 Thread kenn
Register ReadTranslator Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d91c840f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d91c840f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d91c840f Branch:

[01/12] beam git commit: Add URN for Splittable ProcessElement pseudo-primitive

2017-05-25 Thread kenn
Repository: beam Updated Branches: refs/heads/master 50200f23a -> 9cd12907e Add URN for Splittable ProcessElement pseudo-primitive Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/877408e0 Tree:

[06/12] beam git commit: Register WindowIntoTranslator

2017-05-25 Thread kenn
Register WindowIntoTranslator Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/69bb1be4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/69bb1be4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/69bb1be4 Branch:

[04/12] beam git commit: Allow getting URN for class of transform via translator

2017-05-25 Thread kenn
Allow getting URN for class of transform via translator Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0bf4ddbe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0bf4ddbe Diff:

[08/12] beam git commit: Add registration for Read and WindowInto translators

2017-05-25 Thread kenn
Add registration for Read and WindowInto translators Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/afaebb13 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/afaebb13 Diff:

[09/12] beam git commit: Add transform-analysis helpers to ReadTranslation

2017-05-25 Thread kenn
Add transform-analysis helpers to ReadTranslation These helpers allow a runner to extract a source and inspect boundedness without reference to the specific user-facing Java classes Read.Bounded and Read.Unbounded. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[12/12] beam git commit: This closes #3195: [BEAM-2333] Key DirectRunner translators off URN

2017-05-25 Thread kenn
This closes #3195: [BEAM-2333] Key DirectRunner translators off URN URNs for DirectRunner TransformEvaluator and RootInputProvider Add RawPTransform, which can just vend its URN and payload Add transform-analysis helpers to ReadTranslation Add trivial FlattenTranslator to access URN

[11/12] beam git commit: Add RawPTransform, which can just vend its URN and payload

2017-05-25 Thread kenn
Add RawPTransform, which can just vend its URN and payload This is the type that will be returned when a pipeline is deserialized. This also is convenient for direct runner overrides which do not really merit translator registrations, yet URNs need to be known in order to key the evaluator

[07/12] beam git commit: Add trivial FlattenTranslator to access URN

2017-05-25 Thread kenn
Add trivial FlattenTranslator to access URN Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/121631c6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/121631c6 Diff:

[19/50] [abbrv] beam git commit: Fix GcsResourceIdTest in postcommits

2017-05-18 Thread kenn
Fix GcsResourceIdTest in postcommits This test is not a @ValidatesRunner test, so it should not use TestPipelineOptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15ec2cd8 Tree:

[13/50] [abbrv] beam git commit: [BEAM-2290] Fix issue where timestamps weren't set when using CompressedSource

2017-05-18 Thread kenn
[BEAM-2290] Fix issue where timestamps weren't set when using CompressedSource Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/504bd6a8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/504bd6a8 Diff:

[29/50] [abbrv] beam git commit: ApexRunner SDF support

2017-05-18 Thread kenn
ApexRunner SDF support Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5efca02 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f5efca02 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f5efca02 Branch:

[28/50] [abbrv] beam git commit: This closes #3153

2017-05-18 Thread kenn
This closes #3153 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/69522fe6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/69522fe6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/69522fe6 Branch:

[25/50] [abbrv] beam git commit: [BEAM-2299] Run maven install on Windows machine for build/test coverage on Windows

2017-05-18 Thread kenn
[BEAM-2299] Run maven install on Windows machine for build/test coverage on Windows Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/044d1832 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/044d1832 Diff:

[36/50] [abbrv] beam git commit: This closes #3019

2017-05-18 Thread kenn
This closes #3019 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/32fd49aa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/32fd49aa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/32fd49aa Branch:

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

2017-05-18 Thread kenn
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

[07/50] [abbrv] beam git commit: [BEAM-2277] Add ResourceIdTester and test existing ResourceId implementations

2017-05-18 Thread kenn
[BEAM-2277] Add ResourceIdTester and test existing ResourceId implementations A first cut at some of the parts of the ResourceId spec. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6a5ff7b Tree:

[27/50] [abbrv] beam git commit: Fix documentation for the shard_template_name

2017-05-18 Thread kenn
Fix documentation for the shard_template_name Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b3f74044 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b3f74044 Diff:

[24/50] [abbrv] beam git commit: This closes #3148

2017-05-18 Thread kenn
This closes #3148 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cd91eb29 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cd91eb29 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cd91eb29 Branch:

[44/50] [abbrv] beam git commit: Translate a Pipeline in SdkComponents

2017-05-18 Thread kenn
Translate a Pipeline in SdkComponents Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1a05a6a6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1a05a6a6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1a05a6a6

[46/50] [abbrv] beam git commit: This closes #3169

2017-05-18 Thread kenn
This closes #3169 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/467e68f9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/467e68f9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/467e68f9 Branch:

[39/50] [abbrv] beam git commit: Fixes an accidentally found bug in SimpleDoFnRunner

2017-05-18 Thread kenn
Fixes an accidentally found bug in SimpleDoFnRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/24179494 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/24179494 Diff:

[26/50] [abbrv] beam git commit: [BEAM-2299] Run maven install on Windows machine for build/test coverage on Windows.

2017-05-18 Thread kenn
[BEAM-2299] Run maven install on Windows machine for build/test coverage on Windows. This closes #3143 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/13e1be2f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/13e1be2f

[42/50] [abbrv] beam git commit: [TRIVIAL] runners-core: delete placeholder

2017-05-18 Thread kenn
[TRIVIAL] runners-core: delete placeholder This was used to enable checkin of an empty directory, but the directory is no longer empty. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/383a4ada Tree:

[37/50] [abbrv] beam git commit: Removes OldDoFn and its kin from runners-core

2017-05-18 Thread kenn
http://git-wip-us.apache.org/repos/asf/beam/blob/6127f532/runners/core-java/src/test/java/org/apache/beam/runners/core/GroupAlsoByWindowsProperties.java -- diff --git

[38/50] [abbrv] beam git commit: Removes OldDoFn and its kin from runners-core

2017-05-18 Thread kenn
Removes OldDoFn and its kin from runners-core Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6127f532 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6127f532 Diff:

[35/50] [abbrv] beam git commit: Improve Pruning performed by the DirectRunnerApiSurfaceTest

2017-05-18 Thread kenn
Improve Pruning performed by the DirectRunnerApiSurfaceTest Prune the parts of the Core SDK that must be exposed as part of the API surface. The remainder should not be exposed accidentally. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[04/50] [abbrv] beam git commit: Rename FileSystems.setDefaultConfigInWorkers

2017-05-18 Thread kenn
Rename FileSystems.setDefaultConfigInWorkers And document that it's not for users. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3540d47 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3540d47 Diff:

[21/50] [abbrv] beam git commit: Moving the data file for trigger tests to testing/data

2017-05-18 Thread kenn
Moving the data file for trigger tests to testing/data Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/911128b2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/911128b2 Diff:

[22/50] [abbrv] beam git commit: This closes #3144

2017-05-18 Thread kenn
This closes #3144 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b5a8e62 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b5a8e62 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b5a8e62 Branch:

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

2017-05-18 Thread kenn
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:

[05/50] [abbrv] beam git commit: [BEAM-2277] HadoopFileSystem: normalize implementation

2017-05-18 Thread kenn
[BEAM-2277] HadoopFileSystem: normalize implementation * Drop empty authority always * Resolve directories Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15df211c Tree:

[18/50] [abbrv] beam git commit: This closes #3149

2017-05-18 Thread kenn
This closes #3149 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/88ec0086 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/88ec0086 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/88ec0086 Branch:

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

2017-05-18 Thread kenn
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:

[12/50] [abbrv] beam git commit: This closes #3132

2017-05-18 Thread kenn
This closes #3132 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9a43da74 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9a43da74 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9a43da74 Branch:

[43/50] [abbrv] beam git commit: This closes #3160

2017-05-18 Thread kenn
This closes #3160 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d6cc850a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d6cc850a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d6cc850a Branch:

[06/50] [abbrv] beam git commit: Mark FileSystem and related as Experimental

2017-05-18 Thread kenn
Mark FileSystem and related as Experimental Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ec956c85 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ec956c85 Diff:

[02/50] [abbrv] beam git commit: Fix shading of guava testlib

2017-05-18 Thread kenn
Fix shading of guava testlib Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39211638 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39211638 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/39211638 Branch:

[31/50] [abbrv] beam git commit: Use built-in cmp python function in comparing datastore paths

2017-05-18 Thread kenn
Use built-in cmp python function in comparing datastore paths Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0a17c3da Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0a17c3da Diff:

[11/50] [abbrv] beam git commit: [BEAM-2279] Fix archetype breakages

2017-05-18 Thread kenn
[BEAM-2279] Fix archetype breakages * Add version for hadoop-file-system dependency. * Add DirectRunner in test scope in java8, otherwise mvn package fails when another runner profile is enabled. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[32/50] [abbrv] beam git commit: This closes #3155

2017-05-18 Thread kenn
This closes #3155 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aad85553 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aad85553 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aad85553 Branch:

[41/50] [abbrv] beam git commit: This closes #3125

2017-05-18 Thread kenn
This closes #3125 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f314ab3c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f314ab3c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f314ab3c Branch:

[17/50] [abbrv] beam git commit: readAvros should't have proto Message upper bound

2017-05-18 Thread kenn
readAvros should't have proto Message upper bound Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/de1adefd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/de1adefd Diff:

[16/50] [abbrv] beam git commit: This closes #3145

2017-05-18 Thread kenn
This closes #3145 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6e8d8d65 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6e8d8d65 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6e8d8d65 Branch:

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

2017-05-18 Thread kenn
This closes #3131 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4df9079 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4df9079 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4df9079 Branch:

[30/50] [abbrv] beam git commit: This closes #2855

2017-05-18 Thread kenn
This closes #2855 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/754d5d83 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/754d5d83 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/754d5d83 Branch:

[03/50] [abbrv] beam git commit: Remove '/' entirely from determining FileSystem scheme

2017-05-18 Thread kenn
Remove '/' entirely from determining FileSystem scheme Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fbb0de12 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fbb0de12 Diff:

[10/50] [abbrv] beam git commit: This closes #3128

2017-05-18 Thread kenn
This closes #3128 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/89289e49 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/89289e49 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/89289e49 Branch:

[33/50] [abbrv] beam git commit: Adding support for subnetwork in Python Pipelineoptions

2017-05-18 Thread kenn
Adding support for subnetwork in Python Pipelineoptions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/902f27a3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/902f27a3 Diff:

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

2017-05-18 Thread kenn
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:

[45/50] [abbrv] beam git commit: Use stable naming strategy for ByteBuddy invokers

2017-05-18 Thread kenn
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 Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c45ebfb Tree:

[09/50] [abbrv] beam git commit: internal comments

2017-05-18 Thread kenn
internal comments Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f53ceecf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f53ceecf Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f53ceecf Branch:

[01/50] [abbrv] beam git commit: This closes #3126

2017-05-18 Thread kenn
Repository: beam Updated Branches: refs/heads/gearpump-runner 58546aceb -> 99221e739 This closes #3126 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c2a36284 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c2a36284

[08/50] [abbrv] beam git commit: This closes #3121

2017-05-18 Thread kenn
This closes #3121 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9f81fd29 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9f81fd29 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9f81fd29 Branch:

[34/50] [abbrv] beam git commit: This closes #3154

2017-05-18 Thread kenn
This closes #3154 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/529f251b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/529f251b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/529f251b Branch:

[20/50] [abbrv] beam git commit: Fix GcsResourceIdTest in postcommits

2017-05-18 Thread kenn
Fix GcsResourceIdTest in postcommits This closes #3147 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/926157d4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/926157d4 Diff:

[23/50] [abbrv] beam git commit: Remove "Dataflow" from apache_beam __init__.py file

2017-05-18 Thread kenn
Remove "Dataflow" from apache_beam __init__.py file Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/96906aee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/96906aee Diff:

[2/2] beam git commit: This closes #3173: Restore non-recursive globs in GcsUtil

2017-05-18 Thread kenn
This closes #3173: Restore non-recursive globs in GcsUtil Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/18358005 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/18358005 Diff:

[2/2] beam git commit: This closes #3171: [BEAM-2164] Fix generate-sources.sh if directory contains space

2017-05-19 Thread kenn
This closes #3171: [BEAM-2164] Fix generate-sources.sh if directory contains space Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ce00d246 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ce00d246 Diff:

<    4   5   6   7   8   9   10   11   12   13   >