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

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

[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.

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/4] beam git commit: fixup! Hide visibility of internal implementation class

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:

[2/4] beam git commit: address comments

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

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

[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

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

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:

[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

[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()

[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:

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

[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

[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.

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/2] beam git commit: [BEAM-1223][Followup] Reduced visibility for Sum, Min, Max, Mean combine Fns.

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.

[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()

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.

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

[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

[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/8] beam git commit: [BEAM-1186] Broke SampleTest into 2 test classes that support TestPipeline as a JUnit rule.

[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.

[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.

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

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

[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

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

[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

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

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

[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

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

[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

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

[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

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

[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

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.

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

[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

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

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

[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

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:

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

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

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

[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

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

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.

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

[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.

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.

[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.

[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.

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.

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

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

[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

[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

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

[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

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

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

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

[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.

[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.

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:

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

[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.

[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.

[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.

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).

[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).

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

[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

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

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

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

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

[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)

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

[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

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.

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

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

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

[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

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

[2/2] beam git commit: [BEAM-2389] moved GcpCoreApiSurfaceTest to corresponding module, adapted exposed packagees

[BEAM-2389] moved GcpCoreApiSurfaceTest to corresponding module, adapted exposed packagees This closes #3436 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1e16aa20 Tree:

[1/2] beam git commit: [BEAM-2389] moved GcpCoreApiSurfaceTest to corresponding module, adapted exposed packagees

Repository: beam Updated Branches: refs/heads/master 23a34f5df -> 1e16aa201 [BEAM-2389] moved GcpCoreApiSurfaceTest to corresponding module, adapted exposed packagees Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: [BEAM-1187] Improve logging to contain the number of retries done due to IOException and unsuccessful response codes.

Repository: beam Updated Branches: refs/heads/master beb21f472 -> 0b19fb414 [BEAM-1187] Improve logging to contain the number of retries done due to IOException and unsuccessful response codes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: [BEAM-1187] Improve logging to contain the number of retries done due to IOException and unsuccessful response codes

[BEAM-1187] Improve logging to contain the number of retries done due to IOException and unsuccessful response codes This closes #3430 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0b19fb41 Tree:

[1/2] beam git commit: [BEAM-2552] Update Dataflow container version for 2.1.0 release

Repository: beam Updated Branches: refs/heads/release-2.1.0 cb9c8a7a6 -> 74fc43b28 [BEAM-2552] Update Dataflow container version for 2.1.0 release Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aea93fdd Tree:

[2/2] beam git commit: [BEAM-2552] Update Dataflow Java container version for 2.1.0 release

[BEAM-2552] Update Dataflow Java container version for 2.1.0 release This closes #3495 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/74fc43b2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/74fc43b2 Diff:

[2/2] beam git commit: [BEAM-2553] Update Maven exec plugin to 1.6.0 to incorporate messaging improvements

[BEAM-2553] Update Maven exec plugin to 1.6.0 to incorporate messaging improvements This closes #3494 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39c80f64 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39c80f64

[1/2] beam git commit: [BEAM-2553] Update Maven exec plugin to 1.6.0 to incorporate messaging improvements

Repository: beam Updated Branches: refs/heads/master f0549b464 -> 39c80f640 [BEAM-2553] Update Maven exec plugin to 1.6.0 to incorporate messaging improvements Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6ca410a9 Tree:

[2/3] beam git commit: [BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform

[BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6f9f7bcd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6f9f7bcd Diff:

[1/3] beam git commit: [BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform

Repository: beam Updated Branches: refs/heads/master 652a919ed -> 2e3c17a35 http://git-wip-us.apache.org/repos/asf/beam/blob/6f9f7bcd/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/testing/BigqueryMatcher.java

[3/3] beam git commit: [BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform

[BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform This closes #2678 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e3c17a3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e3c17a3 Diff:

[2/2] beam git commit: [BEAM-1871] Move ByteStringCoder to sdks/java/extensions/protobuf

[BEAM-1871] Move ByteStringCoder to sdks/java/extensions/protobuf This closes #2682 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b29d1c83 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b29d1c83 Diff:

[1/2] beam git commit: [BEAM-1871] Move ByteStringCoder to sdks/java/extensions/protobuf

Repository: beam Updated Branches: refs/heads/master 009469972 -> b29d1c83b [BEAM-1871] Move ByteStringCoder to sdks/java/extensions/protobuf Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/03d47845 Tree:

[1/2] beam git commit: [BEAM-2060] Add charset support in XmlSink

Repository: beam Updated Branches: refs/heads/master c5cf90c70 -> 9ff22a4ef [BEAM-2060] Add charset support in XmlSink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43647471 Tree:

[2/2] beam git commit: [BEAM-2060] Add charset support in XmlSink

[BEAM-2060] Add charset support in XmlSink This closes #2702 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9ff22a4e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9ff22a4e Diff:

[1/2] beam git commit: [BEAM-1871] Move RetryHttpRequestInitializer and remove deprecated methods

Repository: beam Updated Branches: refs/heads/master 9ff22a4ef -> 85aaa6297 [BEAM-1871] Move RetryHttpRequestInitializer and remove deprecated methods Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/31e340fb Tree:

  1   2   3   4   5   6   7   8   9   10   >