[2/6] beam git commit: A proposal for a portability framework to execute user definable functions.

2017-01-30 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/0b4b2bec/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClientTest.java -- diff --git

[6/6] beam git commit: [BEAM-1347, BEAM-1348] Beam Fn API Basic Java Harness and Proto Model

2017-01-30 Thread lcwik
[BEAM-1347, BEAM-1348] Beam Fn API Basic Java Harness and Proto Model This closes #1801 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/343176c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/343176c0 Diff:

[1/6] beam git commit: A proposal for a portability framework to execute user definable functions.

2017-01-30 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 582c4a8a4 -> 343176c00 http://git-wip-us.apache.org/repos/asf/beam/blob/0b4b2bec/sdks/java/harness/src/test/java/org/apache/beam/runners/core/BoundedSourceRunnerTest.java --

[3/6] beam git commit: A proposal for a portability framework to execute user definable functions.

2017-01-30 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/0b4b2bec/sdks/java/harness/src/main/java/org/apache/beam/runners/core/BeamFnDataReadRunner.java -- diff --git

[3/4] beam git commit: fixup! Hide visibility of internal implementation class

2017-01-25 Thread lcwik
fixup! Hide visibility of internal implementation class Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a67ff91e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a67ff91e Diff:

[4/4] beam git commit: [BEAM-708] Using AutoValue in BoundedReadFromUnboundedSource

2017-01-25 Thread lcwik
[BEAM-708] Using AutoValue in BoundedReadFromUnboundedSource This closes #1794 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6413299a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6413299a Diff:

[2/4] beam git commit: address comments

2017-01-25 Thread lcwik
address comments Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/968c3112 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/968c3112 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/968c3112 Branch:

[1/4] beam git commit: [BEAM-708] use AutoValue to reduce boilerplate in BoundedReadFromUnboundedSource

2017-01-25 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 95beda69b -> 6413299a2 [BEAM-708] use AutoValue to reduce boilerplate in BoundedReadFromUnboundedSource Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eeec9f12 Tree:

[2/2] beam git commit: [BEAM-1266] Remove value only outputs in Dataflow job representation

2017-01-11 Thread lcwik
[BEAM-1266] Remove value only outputs in Dataflow job representation This closes #1266 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a93e218b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a93e218b Diff:

[1/2] beam git commit: Remove value only outputs in Dataflow job representation

2017-01-11 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 07020c961 -> a93e218ba Remove value only outputs in Dataflow job representation Always define outputs in terms of full windowed value representations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: Use varargs for PipelineOptionsFactory.fromArgs

2017-01-12 Thread lcwik
Use varargs for PipelineOptionsFactory.fromArgs This closes #1772 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f1ea8f95 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f1ea8f95 Diff:

[1/2] beam git commit: Use varargs for PipelineOptionsFactory.fromArgs

2017-01-12 Thread lcwik
Repository: beam Updated Branches: refs/heads/master a93e218ba -> f1ea8f951 Use varargs for PipelineOptionsFactory.fromArgs This simplifies usage of PipelineOptionsFactory within tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/7] beam git commit: [BEAM-1223] Reduced [Sum|Min|Max|Mean]*Fn viability so as to make them an internal implementation detail and prevent external code from employing them for tasks such as pipeline

2017-01-03 Thread lcwik
[BEAM-1223] Reduced [Sum|Min|Max|Mean]*Fn viability so as to make them an internal implementation detail and prevent external code from employing them for tasks such as pipeline translation. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[7/7] beam git commit: [BEAM-1223] Introduced Sum, Min, Max#ofLongs()/ofDoubles()/ofIntegers()

2017-01-03 Thread lcwik
[BEAM-1223] Introduced Sum,Min,Max#ofLongs()/ofDoubles()/ofIntegers() This closes #1723 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d86db15b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d86db15b Diff:

[1/7] beam git commit: [BEAM-1223] Reduced [Sum|Min|Max|Mean]*Fn viability so as to make them an internal implementation detail and prevent external code from employing them for tasks such as pipeline

2017-01-03 Thread lcwik
Repository: beam Updated Branches: refs/heads/master e794f1486 -> d86db15ba http://git-wip-us.apache.org/repos/asf/beam/blob/78a360ea/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/DoFnTest.java -- diff --git

[4/7] beam git commit: [BEAM-1223] Fixed some javadoc.

2017-01-03 Thread lcwik
[BEAM-1223] Fixed some javadoc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/488de7b1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/488de7b1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/488de7b1 Branch:

[6/7] beam git commit: [BEAM-1223] Added the missing javadocs.

2017-01-03 Thread lcwik
[BEAM-1223] Added the missing javadocs. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3e16e325 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3e16e325 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3e16e325

[5/7] beam git commit: [BEAM-1223] Relaxed some visibility concerns for Sum*Fn, Min*Fn, Max*Fn and MeanFn until it's supported by Dataflow.

2017-01-03 Thread lcwik
[BEAM-1223] Relaxed some visibility concerns for Sum*Fn, Min*Fn, Max*Fn and MeanFn until it's supported by Dataflow. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0697b059 Tree:

[3/7] beam git commit: [BEAM-1223] Resolved some type-safety related warnings.

2017-01-03 Thread lcwik
[BEAM-1223] Resolved some type-safety related warnings. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6b68699c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6b68699c Diff:

[2/6] beam git commit: Fix coders to have type information and test coders with components to ensure that they serialize and deserialize correctly with well known coder types.

2017-01-03 Thread lcwik
Fix coders to have type information and test coders with components to ensure that they serialize and deserialize correctly with well known coder types. Jackson requires type information to invoke the coder Jackson module to be able to resolve @type information. The coder Jackson module is

[1/6] beam git commit: Update Dataflow worker image to be able to deserialize well known coder types within TimerOrElementCoder.

2017-01-03 Thread lcwik
Repository: beam Updated Branches: refs/heads/master d86db15ba -> 5c612272d Update Dataflow worker image to be able to deserialize well known coder types within TimerOrElementCoder. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: [BEAM-1223][Followup] Reduced visibility for Sum, Min, Max, Mean combine Fns.

2017-01-04 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 49aeef92a -> 1e2f90c17 [BEAM-1223][Followup] Reduced visibility for Sum,Min,Max,Mean combine Fns. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ab797be6 Tree:

[2/2] beam git commit: [BEAM-1223][Follow-up] Reduced visibility for Sum, Min, Max, Mean.

2017-01-04 Thread lcwik
[BEAM-1223][Follow-up] Reduced visibility for Sum,Min,Max,Mean. This closes #1731 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1e2f90c1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1e2f90c1 Diff:

[4/6] beam git commit: Swap to use initializeCloudObject as customization point for CloudObjects. Hide StandardCoder#getComponents() and have coders only rely on Coder#getCoderArguments()

2017-01-03 Thread lcwik
Swap to use initializeCloudObject as customization point for CloudObjects. Hide StandardCoder#getComponents() and have coders only rely on Coder#getCoderArguments() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b76d3dc

[5/6] beam git commit: Use kind:* for certain well known coder types.

2017-01-03 Thread lcwik
Use kind:* for certain well known coder types. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6947d21b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6947d21b Diff:

[3/6] beam git commit: [BEAM-1231] Use well known coder types in Java

2017-01-03 Thread lcwik
[BEAM-1231] Use well known coder types in Java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3de4108e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3de4108e Diff:

[6/6] beam git commit: [BEAM-1231] Use well known coder types in Java

2017-01-03 Thread lcwik
[BEAM-1231] Use well known coder types in Java This closes #1717 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5c612272 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5c612272 Diff:

[2/2] beam git commit: [BEAM-551] Cache value in NVP.get()

2016-12-29 Thread lcwik
[BEAM-551] Cache value in NVP.get() This closes #1698 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/135d09f5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/135d09f5 Diff:

beam git commit: Fix checkstyle order within ValueProviderTest.java

2016-12-29 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 135d09f5e -> 732411a4c Fix checkstyle order within ValueProviderTest.java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/732411a4 Tree:

[7/8] beam git commit: [BEAM-1186] Brought back some missing test cases involving with NO_LINES.

2016-12-28 Thread lcwik
[BEAM-1186] Brought back some missing test cases involving with NO_LINES. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43789aae Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/43789aae Diff:

[3/8] beam git commit: [BEAM-1186] Broke ApproximateUniqueTest into 3 test classes that support TestPipeline as a JUnit rule.

2016-12-28 Thread lcwik
[BEAM-1186] Broke ApproximateUniqueTest into 3 test classes that support TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3aaa1e3f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3aaa1e3f

[1/8] beam git commit: [BEAM-1186] Migrated BigtableIOTest to use TestPipeline as a JUnit rule by stabilizing runReadTest's (read) transform name.

2016-12-28 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 178371ae3 -> b6944cd62 [BEAM-1186] Migrated BigtableIOTest to use TestPipeline as a JUnit rule by stabilizing runReadTest's (read) transform name. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/8] beam git commit: [BEAM-1186] Broke SampleTest into 2 test classes that support TestPipeline as a JUnit rule.

2016-12-28 Thread lcwik
[BEAM-1186] Broke SampleTest into 2 test classes that support TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9faa5aba Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9faa5aba Diff:

[8/8] beam git commit: [BEAM-1186] Migrating the remaining tests to use TestPipeline as a JUnit rule.

2016-12-28 Thread lcwik
[BEAM-1186] Migrating the remaining tests to use TestPipeline as a JUnit rule. This closes #1675 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6944cd6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6944cd6 Diff:

[6/8] beam git commit: Revised the javadoc to include TestPipeline as a JUnit usage.

2016-12-28 Thread lcwik
Revised the javadoc to include TestPipeline as a JUnit usage. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/239848c1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/239848c1 Diff:

[1/2] beam git commit: [BEAM-1226] Add support for well known coder types to Apache Beam python SDK

2016-12-28 Thread lcwik
def estimate_size(self, value, nested=False): @@ -535,7 +535,7 @@ class WindowedValueCoderImpl(StreamCoderImpl): """A coder for windowed values.""" def __init__(self, value_coder, timestamp_coder, window_coder): -# TODO(robertwb): Do we need the ability to customize t

[2/2] beam git commit: [BEAM-1226] Add support for well known coder types to Apache Beam Python SDK

2016-12-28 Thread lcwik
[BEAM-1226] Add support for well known coder types to Apache Beam Python SDK This closes #1709 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2999e229 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2999e229 Diff:

[1/2] incubator-beam git commit: Assert transform without side inputs

2016-12-27 Thread lcwik
Repository: incubator-beam Updated Branches: refs/heads/python-sdk 41bf6f8b4 -> b2728cf13 Assert transform without side inputs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1c795c10 Tree:

[2/2] incubator-beam git commit: [BEAM-1216] Assert transform without side inputs

2016-12-27 Thread lcwik
[BEAM-1216] Assert transform without side inputs This closes #1699 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b2728cf1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b2728cf1 Diff:

[1/2] incubator-beam git commit: Add experiments alias for DebugOptions

2016-12-22 Thread lcwik
Repository: incubator-beam Updated Branches: refs/heads/python-sdk 7c5382b33 -> c8a8bb21e Add experiments alias for DebugOptions Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/df663884 Tree:

[2/2] incubator-beam git commit: Add experiments alias for DebugOptions

2016-12-22 Thread lcwik
Add experiments alias for DebugOptions This closes #1682 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c8a8bb21 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c8a8bb21 Diff:

[2/2] beam git commit: [BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent name usage

2017-04-12 Thread lcwik
[BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent name usage This closes #2511 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/435c3b42 Tree:

[1/2] beam git commit: [BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent tag usage

2017-04-12 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 571631a5e -> 435c3b426 [BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent tag usage Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: [BEAM-1786, BEAM-1871] Add the ability to register coder factories

2017-04-20 Thread lcwik
[BEAM-1786, BEAM-1871] Add the ability to register coder factories This closes #2605 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a12d02 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a12d02 Diff:

[1/2] beam git commit: [BEAM-1786, BEAM-1871] Add the ability to register coder factories for classes allowing TableRowJsonCoder to move to sdks/java/io/google-cloud-platform

2017-04-20 Thread lcwik
Repository: beam Updated Branches: refs/heads/master b47fd52cb -> 36a12d023 [BEAM-1786, BEAM-1871] Add the ability to register coder factories for classes allowing TableRowJsonCoder to move to sdks/java/io/google-cloud-platform Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[2/2] beam git commit: [BEAM-2040] Upgrade autovalue

2017-04-20 Thread lcwik
[BEAM-2040] Upgrade autovalue This closes #2624 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bda16078 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bda16078 Diff:

[1/2] beam git commit: Upgrade autovalue

2017-04-20 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 28665490f -> bda16078e Upgrade autovalue I believe we are occasionally being hit by these issues fixed in release. > We guard against spurious exceptions due to a JDK bug in reading resources > from jars. (#365) > > We don't propagate an

[2/2] beam git commit: [BEAM-2014] Upgrade to Google Auth 0.6.1

2017-04-19 Thread lcwik
[BEAM-2014] Upgrade to Google Auth 0.6.1 This closes #2590 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7515c260 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7515c260 Diff:

[1/2] beam git commit: [BEAM-2014] Upgrade to Google Auth 0.6.1

2017-04-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 19ae87762 -> 7515c2602 [BEAM-2014] Upgrade to Google Auth 0.6.1 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/be4f8b7f Tree:

[1/2] beam git commit: [BEAM-1347] Update protos related to State API for prototyping purposes.

2017-04-14 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 4daac6644 -> 6bf42622c [BEAM-1347] Update protos related to State API for prototyping purposes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/25d77b12 Tree:

[2/2] beam git commit: [BEAM-1347] Update protos related to State API for prototyping purposes

2017-04-14 Thread lcwik
[BEAM-1347] Update protos related to State API for prototyping purposes This closes #2518 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6bf42622 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6bf42622 Diff:

[2/2] beam git commit: est all Known Coders to ensure they Serialize via URN

2017-04-13 Thread lcwik
est all Known Coders to ensure they Serialize via URN This closes #2517 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4c4fdf24 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4c4fdf24 Diff:

[1/2] beam git commit: Test all Known Coders to ensure they Serialize via URN

2017-04-13 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 21a2b96a1 -> 4c4fdf244 Test all Known Coders to ensure they Serialize via URN Fix Coders to not encode VarIntCoders as VarLongCoders, and VarLongCoders not as known coders. Ensure that all known coders are tested. Use getComponents rather

[2/2] beam git commit: [BEAM-2013] Upgrade to Jackson 2.8.8

2017-04-19 Thread lcwik
[BEAM-2013] Upgrade to Jackson 2.8.8 This closes #2589 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d54ace4f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d54ace4f Diff:

[1/2] beam git commit: Modify types for input PCollections of Flatten transform to that of the output PCollection

2017-04-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 1721cea27 -> 6224556be Modify types for input PCollections of Flatten transform to that of the output PCollection Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: [BEAM-1956] Modify types for input PCollections of Flatten transform

2017-04-19 Thread lcwik
[BEAM-1956] Modify types for input PCollections of Flatten transform This closes #2543 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6224556b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6224556b Diff:

[1/2] beam git commit: [BEAM-2013] Upgrade to Jackson 2.8.8

2017-04-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 7515c2602 -> d54ace4f3 [BEAM-2013] Upgrade to Jackson 2.8.8 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0650d666 Tree:

[1/2] beam git commit: [BEAM-1871] Remove another depedendency by moving TestCredential

2017-04-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 4ab74bf74 -> 1721cea27 [BEAM-1871] Remove another depedendency by moving TestCredential Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c0baf4ce Tree:

[2/2] beam git commit: [BEAM-1871] Remove another depedendency by moving TestCredential

2017-04-19 Thread lcwik
[BEAM-1871] Remove another depedendency by moving TestCredential This closes #2598 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1721cea2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1721cea2 Diff:

[1/2] beam git commit: Validates that input and output GCS paths specify a bucket

2017-04-21 Thread lcwik
Repository: beam Updated Branches: refs/heads/master f3806f64f -> 0527f6b66 Validates that input and output GCS paths specify a bucket Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4efd7eb8 Tree:

[2/2] beam git commit: Update Dataflow Worker Version

2017-04-21 Thread lcwik
Update Dataflow Worker Version This closes #2631 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/552ddb4a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/552ddb4a Diff:

[2/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/be92f595/sdks/java/extensions/gcp-core/src/main/java/org/apache/beam/sdk/util/IntervalBoundedExponentialBackOff.java -- diff --git

[5/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/be92f595/sdks/java/core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/GcsUtil.java

[4/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/be92f595/sdks/java/core/src/test/java/org/apache/beam/sdk/util/GcpProjectUtilTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/GcpProjectUtilTest.java

[6/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
[BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/be92f595 Tree:

[7/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
[BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over. This closes #2561 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6d3fe51c Tree:

[3/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
http://git-wip-us.apache.org/repos/asf/beam/blob/be92f595/sdks/java/extensions/gcp-core/src/main/java/org/apache/beam/sdk/options/GcsOptions.java -- diff --git

[1/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

2017-04-18 Thread lcwik
Repository: beam Updated Branches: refs/heads/master ed52d328d -> 6d3fe51ce http://git-wip-us.apache.org/repos/asf/beam/blob/be92f595/sdks/java/extensions/gcp-core/src/test/java/org/apache/beam/sdk/util/GcsUtilTest.java --

[1/3] beam git commit: [BEAM-2060] Use withCharset(Charset) for the user facing API

2017-04-24 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 9c396826c -> d6dddee23 [BEAM-2060] Use withCharset(Charset) for the 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/7c7ece30 Tree:

[3/3] beam git commit: [BEAM-2060] Allow to specify charset in XmlIO

2017-04-24 Thread lcwik
[BEAM-2060] Allow to specify charset in XmlIO This closes #2660 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d6dddee2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d6dddee2 Diff:

[2/3] beam git commit: [BEAM-2060] Allow to specify charset in XmlIO

2017-04-24 Thread lcwik
[BEAM-2060] Allow to specify charset in XmlIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ffc77813 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ffc77813 Diff:

[1/2] beam git commit: Update pom.xml

2017-04-24 Thread lcwik
Repository: beam Updated Branches: refs/heads/master e5507d827 -> 9c396826c Update pom.xml Upgrade dataflow.version to v1b3-rev196-1.22.0 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fe26348a Tree:

[2/2] beam git commit: [BEAM-2054] Update pom.xml: upgrade dataflow.version to v1b3-rev196-1.22.0

2017-04-24 Thread lcwik
[BEAM-2054] Update pom.xml: upgrade dataflow.version to v1b3-rev196-1.22.0 This closes #2651 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9c396826 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9c396826 Diff:

[2/2] beam git commit: Properly Declare Protobuf extension dependencies

2017-04-24 Thread lcwik
Properly Declare Protobuf extension dependencies This closes #2669 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/02e60a5c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/02e60a5c Diff:

[1/2] beam git commit: Properly Declare Protobuf extension dependencies

2017-04-24 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 57535f35e -> 02e60a5c5 Properly Declare Protobuf extension dependencies Import the correct ProtoCoder in BigtableIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: [BEAM-1347] Add utility to be able to model inbound reading as a single input stream

2017-08-03 Thread lcwik
Repository: beam Updated Branches: refs/heads/master d4f9e9268 -> 38f189063 [BEAM-1347] Add utility to be able to model inbound reading as a single input stream Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ac7f9739

[2/2] beam git commit: [BEAM-1347] Add utility to be able to model inbound reading as a single input stream

2017-08-03 Thread lcwik
[BEAM-1347] Add utility to be able to model inbound reading as a single input stream This closes #3638 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38f18906 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/38f18906

[2/2] beam git commit: [BEAM-2298] Making LocalFileSystem default and stripping file spec prefixes.

2017-08-03 Thread lcwik
[BEAM-2298] Making LocalFileSystem default and stripping file spec prefixes. This closes #3521 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d2133d34 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d2133d34 Diff:

[1/2] beam git commit: Add local filesystem as default and strip away prefix from local files in pipeline options.

2017-08-03 Thread lcwik
Repository: beam Updated Branches: refs/heads/master de0148c3e -> d2133d34b Add local filesystem as default and strip away prefix from local files in pipeline options. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/3] beam git commit: [BEAM-1347] Add DoFnRunner specific to Fn Api.

2017-07-07 Thread lcwik
Repository: beam Updated Branches: refs/heads/master f62586a08 -> 56e4251de [BEAM-1347] Add DoFnRunner specific to Fn Api. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7da08c98 Tree:

[3/3] beam git commit: [BEAM-1347] Create a DoFnRunner specific for the Fn API

2017-07-07 Thread lcwik
[BEAM-1347] Create a DoFnRunner specific for the Fn API This closes #3432 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/56e4251d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/56e4251d Diff:

[2/3] beam git commit: [BEAM-1347] Rename DoFnRunnerFactory to FnApiDoFnRunner.

2017-07-07 Thread lcwik
[BEAM-1347] Rename DoFnRunnerFactory to FnApiDoFnRunner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2295b905 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2295b905 Diff:

[2/2] beam git commit: [BEAM-2556] Add client-side throttling.

2017-07-11 Thread lcwik
[BEAM-2556] Add client-side throttling. This closes #3507 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a22f1a05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a22f1a05 Diff:

[1/2] beam git commit: Add client-side throttling.

2017-07-11 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 138641f14 -> a22f1a05a Add client-side throttling. The approach used is as described in https://landing.google.com/sre/book/chapters/handling-overload.html#client-side-throttling-a7sYUg . By backing off individual workers in response to

[2/2] beam git commit: [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts).

2017-07-10 Thread lcwik
[BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts). This closes #3482 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9d48bd5e Tree:

[1/2] beam git commit: [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts).

2017-07-10 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 9f904dc00 -> 9d48bd5e8 [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/521488f8

[2/2] beam git commit: [BEAM-2658] register SerializableCoder last

2017-07-26 Thread lcwik
[BEAM-2658] register SerializableCoder last This closes #3617 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/69a51c98 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/69a51c98 Diff:

[1/2] beam git commit: [BEAM-2658] register DefaultCoder first and SerializableCoder last

2017-07-26 Thread lcwik
Repository: beam Updated Branches: refs/heads/master bc72c9405 -> 69a51c988 [BEAM-2658] register DefaultCoder first and SerializableCoder last Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/809a7f86 Tree:

[1/2] beam git commit: [BEAM-2642] Update Google Auth to 0.7.1

2017-07-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master a6f460fe3 -> 4d1db2265 [BEAM-2642] Update Google Auth to 0.7.1 Google auth libraries 0.6.1 and 0.7.1 have the same versions of dependencies. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: Increase the gRPC message size to max value

2017-07-19 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 4d1db2265 -> eb0850ef8 Increase the gRPC message size to max value Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b424aa04 Tree:

[2/2] beam git commit: Increase the gRPC message size to max value

2017-07-19 Thread lcwik
Increase the gRPC message size to max value This closes #3586 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb0850ef Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eb0850ef Diff:

[2/2] beam git commit: [BEAM-2642] Update Google Auth to 0.7.1

2017-07-19 Thread lcwik
[BEAM-2642] Update Google Auth to 0.7.1 This closes #3596 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4d1db226 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4d1db226 Diff:

[beam-site] branch asf-site2 deleted (was 4e9082b)

2017-07-12 Thread lcwik
This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch asf-site2 in repository https://gitbox.apache.org/repos/asf/beam-site.git. was 4e9082b Drop the word reviewer from the contribution guide This change permanently discards the following

[2/2] beam git commit: [BEAM-2373] Upgrade commons-compress dependency version to 1.14

2017-06-29 Thread lcwik
[BEAM-2373] Upgrade commons-compress dependency version to 1.14 This closes #3252 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36900731 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36900731 Diff:

[1/2] beam git commit: [BEAM-2373] Upgrade commons-compress dependency version to 1.14

2017-06-29 Thread lcwik
Repository: beam Updated Branches: refs/heads/master ae3a75263 -> 369007316 [BEAM-2373] Upgrade commons-compress dependency version to 1.14 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5744fa84 Tree:

[2/2] beam git commit: Properly convert milliseconds whether there's less than 3/more than 9 digits.

2017-06-30 Thread lcwik
Properly convert milliseconds whether there's less than 3/more than 9 digits. This closes #3469 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f75dfe71 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f75dfe71 Diff:

[1/2] beam git commit: Properly convert milliseconds whether there's less than 3/more than 9 digits. TimeUtil did not properly convert (and returned null) when the number of digits for fractions of se

2017-06-30 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 893bf428a -> f75dfe711 Properly convert milliseconds whether there's less than 3/more than 9 digits. TimeUtil did not properly convert (and returned null) when the number of digits for fractions of seconds was less than 3 digits or more than

[1/3] beam git commit: BeamSql: refactor the MockedBeamSqlTable and related tests

2017-07-05 Thread lcwik
Repository: beam Updated Branches: refs/heads/DSL_SQL 7ba77dd43 -> ca2bc723d BeamSql: refactor the MockedBeamSqlTable and related tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/21497194 Tree:

[3/3] beam git commit: [BEAM-2515] BeamSql: refactor the MockedBeamSqlTable and related tests

2017-07-05 Thread lcwik
[BEAM-2515] BeamSql: refactor the MockedBeamSqlTable and related tests This closes #3478 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ca2bc723 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ca2bc723 Diff:

[2/3] beam git commit: MockedBeamSqlTable -> MockedBoundedTable

2017-07-05 Thread lcwik
MockedBeamSqlTable -> MockedBoundedTable Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bc66698e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bc66698e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bc66698e

  1   2   3   4   5   6   7   8   9   10   >