[2/2] incubator-beam git commit: Closes #477

Closes #477 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f57e66c4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f57e66c4 Diff:

[2/2] incubator-beam git commit: Closes #454

Closes #454 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0a3425e7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0a3425e7 Diff:

[1/2] incubator-beam git commit: Replace GcsPath by IOChannelFactory in WordCount.

Repository: incubator-beam Updated Branches: refs/heads/master 41fe8eecf -> 0a3425e77 Replace GcsPath by IOChannelFactory in WordCount. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1239f111 Tree:

[GitHub] incubator-beam pull request #477: CrashingRunner: cleanup some code

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/477 CrashingRunner: cleanup some code make it final, fix an error message, remove unused code You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] incubator-beam pull request #476: [BEAM-350] DataflowPipelineJob: Retry mess...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/476 [BEAM-350] DataflowPipelineJob: Retry messages, metrics, and status polls At some point in the past, we decided to use a rawDataflowClient that does not do retries when checking job

[2/2] incubator-beam git commit: Closes #451

Closes #451 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3b66f591 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3b66f591 Diff:

[1/2] incubator-beam git commit: Improve BigQueryIO validation for streaming WriteDisposition

Repository: incubator-beam Updated Branches: refs/heads/master f8c59bd6c -> 3b66f5919 Improve BigQueryIO validation for streaming WriteDisposition Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/df9a78b9

[1/2] incubator-beam git commit: Update DataflowPipelineRunner worker container version

Repository: incubator-beam Updated Branches: refs/heads/master 021fa1e5f -> 414bb4bc3 Update DataflowPipelineRunner worker container version Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f117f712 Tree:

[1/2] incubator-beam git commit: Closes #440

Repository: incubator-beam Updated Branches: refs/heads/master 2f46bc004 -> 11eb9f65f Closes #440 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11eb9f65 Tree:

[2/2] incubator-beam git commit: Modified range tracker to use first response seen as start key

Modified range tracker to use first response seen as start key Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/172d4fdc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/172d4fdc Diff:

[2/2] incubator-beam git commit: Closes #472

Closes #472 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/462453d2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/462453d2 Diff:

[1/2] incubator-beam git commit: Run NeedsRunner tests in Runner Core on the DirectRunner

Repository: incubator-beam Updated Branches: refs/heads/master 9c8cf5e21 -> 462453d23 Run NeedsRunner tests in Runner Core on the DirectRunner This ensures that all runner tests in runners/core-java are executed in the standard maven build. Project:

[2/2] incubator-beam git commit: Closes #470

Closes #470 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1bb9020 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1bb9020 Diff:

[1/2] incubator-beam git commit: Package javadoc for org.apache.beam.sdk.transforms.display

Repository: incubator-beam Updated Branches: refs/heads/master 63e7b1dce -> a1bb90207 Package javadoc for org.apache.beam.sdk.transforms.display Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2e0836e7

[1/2] incubator-beam git commit: Closes #463

Repository: incubator-beam Updated Branches: refs/heads/master 315b3c8e3 -> 63e7b1dce Closes #463 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63e7b1dc Tree:

[2/2] incubator-beam git commit: Explicitly set the Runner in TestFlinkPipelineRunner

Explicitly set the Runner in TestFlinkPipelineRunner This ensures that the created PipelineOptions are valid if the DirectRunner is not on the classpath. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: CompressedSourceTest: simplify

CompressedSourceTest: simplify We should use random.nextBytes(buff) instead of making the array in a loop. The code we now point to is the same as the for loop, so the test continues to pass. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[1/2] incubator-beam git commit: Closes #456

Repository: incubator-beam Updated Branches: refs/heads/master 522762452 -> f9a9214dd Closes #456 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f9a9214d Tree:

[GitHub] incubator-beam pull request #456: CompressedSourceTest: simplify

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/456 CompressedSourceTest: simplify We should use random.nextBytes(buff) instead of making the array in a loop. The code we now point to is the same as the for loop, so the test

[2/2] incubator-beam git commit: Closes #447

Closes #447 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/60964b61 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/60964b61 Diff:

[1/2] incubator-beam git commit: [BEAM-334] DataflowPipelineRunner: bump environment major version

Repository: incubator-beam Updated Branches: refs/heads/master 829121960 -> 60964b611 [BEAM-334] DataflowPipelineRunner: bump environment major version Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #447: [BEAM-334] DataflowPipelineRunner: bump en...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/447 [BEAM-334] DataflowPipelineRunner: bump environment major version R: @peihe @tgroh either will do You can merge this pull request into a Git repository by running: $ git pull

[1/2] incubator-beam git commit: FileBasedSink: Detect bad shard name templates

Repository: incubator-beam Updated Branches: refs/heads/master 61d8cf2c4 -> 39da22c76 FileBasedSink: Detect bad shard name templates This is particularly relevant when TextIO.Write.withoutSharding() is used: [BEAM-159]. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo

[2/2] incubator-beam git commit: Closes #436

Closes #436 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/39da22c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/39da22c7 Diff:

[2/2] incubator-beam git commit: Merge branch 'master' into release-0.1.0-incubating

Merge branch 'master' into release-0.1.0-incubating Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8bf31193 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8bf31193 Diff:

[GitHub] incubator-beam pull request #434: Use Apache's release to produce the source...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/434 Use Apache's release to produce the source release And use final-name to override the artifact and directory names You can merge this pull request into a Git repository by running

[4/4] incubator-beam git commit: Merge branch 'master' into release-0.1.0-incubating

Merge branch 'master' into release-0.1.0-incubating Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/492d919f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/492d919f Diff:

[3/4] incubator-beam git commit: Fix pom shading of Guava

Fix pom shading of Guava There are two packages: com.google.common and com.google.thirdparty. Both need to be repackaged/relocated, but we only had com.google.common in a few places. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[1/2] incubator-beam git commit: [BEAM-132] pom.xml: skip source-release assembly

Repository: incubator-beam Updated Branches: refs/heads/master ce87f377b -> 3f3dffcb6 [BEAM-132] pom.xml: skip source-release assembly We do this separately via our own assembly. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: Closes #433

Closes #433 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3f3dffcb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3f3dffcb Diff:

[GitHub] incubator-beam pull request #433: [BEAM-132] pom.xml: skip source-release as...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/433 [BEAM-132] pom.xml: skip source-release assembly We do this separately via our own assembly. You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] incubator-beam pull request #431: Fix pom shading of Guava

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/431 Fix pom shading of Guava There are two packages: com.google.common and com.google.thirdparty. Both need to be repackaged/relocated, but we only had com.google.common in a few places

[1/2] incubator-beam git commit: [BEAM-48] Code cleanup in BigQueryIO

Repository: incubator-beam Updated Branches: refs/heads/master 1a34bf038 -> 5a80bdc61 [BEAM-48] Code cleanup in BigQueryIO 1. Use toJsonString() to avoid try catch 2. add getTableWithDefaultProject in BigQuery.Write Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: Closes #369

Closes #369 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5a80bdc6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5a80bdc6 Diff:

[1/2] incubator-beam git commit: KafkaIO javadoc update

Repository: incubator-beam Updated Branches: refs/heads/master b9845a700 -> fcf5bc71d KafkaIO javadoc update Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3f79c48c Tree:

[2/2] incubator-beam git commit: Closes #425

Closes #425 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fcf5bc71 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fcf5bc71 Diff:

[2/2] incubator-beam git commit: Closes #424

Closes #424 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b9845a70 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b9845a70 Diff:

[1/2] incubator-beam git commit: [BEAM-292] Write: always produce at least 1 WriteT

Repository: incubator-beam Updated Branches: refs/heads/master aaab15766 -> b9845a700 [BEAM-292] Write: always produce at least 1 WriteT Write has a degenerate case wherein, if no elements were in the written PCollection, the finalize step will get produced with nothing to finalize. This

[GitHub] incubator-beam pull request #408: [BEAM-318] AvroCoder,Source: workaround AV...

Github user dhalperi closed the pull request at: https://github.com/apache/incubator-beam/pull/408 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[GitHub] incubator-beam pull request #424: [BEAM-292] Write: always produce at least ...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/424 [BEAM-292] Write: always produce at least 1 WriteT Write has a degenerate case wherein, if no elements were in the written PCollection, the finalize step will get produced with nothing

[1/2] incubator-beam git commit: Closes #421

Repository: incubator-beam Updated Branches: refs/heads/master 523e820b0 -> fe1889316 Closes #421 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fe188931 Tree:

[2/2] incubator-beam git commit: Fix validation in PubsubIO

Fix validation in PubsubIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/135aabd6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/135aabd6 Diff:

[2/3] incubator-beam git commit: Use Structural Value keys instead of User Values

Use Structural Value keys instead of User Values This fixes problems with lookup by basing entirely on structural equality. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e3cc4fa4 Tree:

[3/3] incubator-beam git commit: Closes #411

Closes #411 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1da797d8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1da797d8 Diff:

[1/3] incubator-beam git commit: Use Structural Value keys instead of User Values

Repository: incubator-beam Updated Branches: refs/heads/master b9a8cbeff -> 1da797d8f http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e3cc4fa4/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StructuralKeyTest.java

[GitHub] incubator-beam pull request: [BEAM-318] AvroCoder,Source: workaround AVRO-60...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/408 [BEAM-318] AvroCoder,Source: workaround AVRO-607 See https://issues.apache.org/jira/browse/AVRO-607 You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] incubator-beam pull request: [BEAM-53] PubSub: build fixups

Github user dhalperi closed the pull request at: https://github.com/apache/incubator-beam/pull/367 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[1/2] incubator-beam git commit: AvroSource: synchronization fix

Repository: incubator-beam Updated Branches: refs/heads/master 2ffecfda2 -> 731c03036 AvroSource: synchronization fix Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/20a58873 Tree:

[2/2] incubator-beam git commit: Verify in unit test that BigQuery executing project is used.

Verify in unit test that BigQuery executing project is used. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70c1e2c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70c1e2c7 Diff:

[1/2] incubator-beam git commit: Closes #376

Repository: incubator-beam Updated Branches: refs/heads/master ffed1d479 -> 78c8c528e Closes #376 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/78c8c528 Tree:

[2/4] incubator-beam git commit: Correctly forward dependsOnlyOnWindow(), etc, in WindowingStrategy

Correctly forward dependsOnlyOnWindow(), etc, in WindowingStrategy Previously, WindowingStrategy contained an implemenation of OutputTimeFn that did not properly forward these important methods. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[4/4] incubator-beam git commit: Closes #385

Closes #385 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/65db44ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/65db44ce Diff:

[1/4] incubator-beam git commit: Improve the inheritance API for OutputTimeFn

Repository: incubator-beam Updated Branches: refs/heads/master a5d343b23 -> 65db44ce6 Improve the inheritance API for OutputTimeFn Previously, OutputTimeFn.Defaults enforced that any subclass *could not* return true for dependsOnlyOnWindow(), to encourage such subclasses to extend

[2/2] incubator-beam git commit: Closes #381

Closes #381 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/27abf446 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/27abf446 Diff:

[1/2] incubator-beam git commit: PubsubIO: make translation to Dataflow service compatible

Repository: incubator-beam Updated Branches: refs/heads/master c91390026 -> 9934a4335 PubsubIO: make translation to Dataflow service compatible Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6a74143a

[GitHub] incubator-beam pull request: AvroSource: synchronization fix

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/373 AvroSource: synchronization fix You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam limited-parallelism

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

This closes #353 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4755c5a7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4755c5a7 Diff:

[1/2] incubator-beam git commit: BoundedReader: add getSplitPoints{Consumed, Remaining}

Repository: incubator-beam Updated Branches: refs/heads/master efd1f95b6 -> 4755c5a78 BoundedReader: add getSplitPoints{Consumed,Remaining} And implement and test it for common sources OffsetBasedReader: test limited parallelism signals AvroSource: rewrite to support remaining parallelism

[1/2] incubator-beam git commit: Closes #352

Repository: incubator-beam Updated Branches: refs/heads/master d7952959f -> efd1f95b6 Closes #352 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/efd1f95b Tree:

[2/2] incubator-beam git commit: [BEAM-48] Add BigQueryTornadoes integration test

[BEAM-48] Add BigQueryTornadoes integration test Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/89d20a2d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/89d20a2d Diff:

[2/2] incubator-beam git commit: Closes #368

Closes #368 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d7952959 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d7952959 Diff:

[GitHub] incubator-beam pull request: [BEAM-53] PubSub: build fixups

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/367 [BEAM-53] PubSub: build fixups * Always RunWith on a unit test * Mockito bugfix for Java 9 You can merge this pull request into a Git repository by running: $ git pull https

[1/2] incubator-beam git commit: DisplayData: a few build fixups

Repository: incubator-beam Updated Branches: refs/heads/master d0b9ca910 -> 402fb70c4 DisplayData: a few build fixups Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6c10a1d7 Tree:

[2/2] incubator-beam git commit: Closes #360

Closes #360 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/402fb70c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/402fb70c Diff:

incubator-beam git commit: Closes #346

Repository: incubator-beam Updated Branches: refs/heads/master 26941f152 -> d0b9ca910 Closes #346 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d0b9ca91 Tree:

incubator-beam git commit: PubsubIO: integrate the new PubsubUnboundedSource and Sink

Repository: incubator-beam Updated Branches: refs/heads/master 662e49351 -> 26941f152 PubsubIO: integrate the new PubsubUnboundedSource and Sink Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/26941f15

[GitHub] incubator-beam pull request: DisplayData: a few build fixups

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/360 DisplayData: a few build fixups You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam build-fixups Alternatively

[1/2] incubator-beam git commit: Add a compatibility stub of GABWViaWindowSetDoFn

Repository: incubator-beam Updated Branches: refs/heads/master 3edae9b8b -> f184bcf37 Add a compatibility stub of GABWViaWindowSetDoFn Direct calls to `org.apache.beam.sdk.util.GroupAlsoByWindowViaWindowSetDoFn#create` failed following the rename in 892ead2c. This re-introduces that method

[2/2] incubator-beam git commit: Closes #351

Closes #351 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f184bcf3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f184bcf3 Diff:

[3/3] incubator-beam git commit: Pub/sub unbounded source

Pub/sub unbounded source Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f55fb887 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f55fb887 Diff:

[1/3] incubator-beam git commit: Closes #332

Repository: incubator-beam Updated Branches: refs/heads/master cc64d654c -> 3edae9b8b Closes #332 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3edae9b8 Tree:

[1/2] incubator-beam git commit: Closes #341

Repository: incubator-beam Updated Branches: refs/heads/master 638cc2071 -> d627266d8 Closes #341 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d627266d Tree:

[GitHub] incubator-beam pull request: checkstyle: enforce where line breaks...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/341 checkstyle: enforce where line breaks happen We should do it consistently throughout the SDK. Only a few fixups. Ported from: https://github.com/checkstyle/checkstyle/blob

[1/3] incubator-beam git commit: checkstyle: ban netty internal classes

Repository: incubator-beam Updated Branches: refs/heads/master ee198d4e9 -> 0f2e6f37e checkstyle: ban netty internal classes Accidentally used Netty's ThreadLocalRandom and want to prevent further uses Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[3/3] incubator-beam git commit: Closes #336

Closes #336 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0f2e6f37 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0f2e6f37 Diff:

[2/2] incubator-beam git commit: Closes #337

Closes #337 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ee198d4e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ee198d4e Diff:

[1/2] incubator-beam git commit: [BEAM-48] Remove BigQueryIOTranslator

Repository: incubator-beam Updated Branches: refs/heads/master c0efe568e -> ee198d4e9 [BEAM-48] Remove BigQueryIOTranslator This is no longer needed for the Cloud Dataflow service. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request: checkstyle.xml: blacklist more bad im...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/336 checkstyle.xml: blacklist more bad imports from api client package And fixup existing uses You can merge this pull request into a Git repository by running: $ git pull https

[1/2] incubator-beam git commit: Closes #334

Repository: incubator-beam Updated Branches: refs/heads/master 1c23dc40c -> 9b5cf3247 Closes #334 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9b5cf324 Tree:

[2/2] incubator-beam git commit: Fixup the log message format in GcsUtil.copy()

Fixup the log message format in GcsUtil.copy() Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/80195ffb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/80195ffb Diff:

[1/2] incubator-beam git commit: [BEAM-282] Remove the RunnableOnService from testPassThroughThenCleanupExecuted()

Repository: incubator-beam Updated Branches: refs/heads/master 470b3d124 -> 1c23dc40c [BEAM-282] Remove the RunnableOnService from testPassThroughThenCleanupExecuted() Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: Closes #333

Closes #333 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1c23dc40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1c23dc40 Diff:

[3/3] incubator-beam git commit: [BEAM-48] Implement BigQueryIO.Read as Source

[BEAM-48] Implement BigQueryIO.Read as Source Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/987350b7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/987350b7 Diff:

[2/3] incubator-beam git commit: [BEAM-48] Implement BigQueryIO.Read as Source

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/987350b7/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java

[1/2] incubator-beam git commit: [BEAM-117] Window display data should be safe for null windowFn

Repository: incubator-beam Updated Branches: refs/heads/master 9f105ec17 -> a760b4c83 [BEAM-117] Window display data should be safe for null windowFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: Closes #330

Closes #330 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a760b4c8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a760b4c8 Diff:

[2/2] incubator-beam git commit: [BEAM-117] Runners should be resilient to DisplayData failure

[BEAM-117] Runners should be resilient to DisplayData failure Display data is collected from PTransforms at Pipeline construction time. Collecting display data runs user code from provided transforms and fn's. These components should be designed not to throw during pipeline construction, however

[1/2] incubator-beam git commit: Closes #315

Repository: incubator-beam Updated Branches: refs/heads/master d2ad0ed31 -> 9f105ec17 Closes #315 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f105ec1 Tree:

[2/2] incubator-beam git commit: [BEAM-53] Add PubsubUnboundedSink and tests

[BEAM-53] Add PubsubUnboundedSink and tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/040f8f98 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/040f8f98 Diff:

[1/2] incubator-beam git commit: Closes #171

Repository: incubator-beam Updated Branches: refs/heads/master 123674f4b -> 2fbc0ea3a Closes #171 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2fbc0ea3 Tree:

[1/2] incubator-beam git commit: Closes #289

Repository: incubator-beam Updated Branches: refs/heads/master 272493ed7 -> 31da925ca Closes #289 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/31da925c Tree:

[1/2] incubator-beam git commit: FileBasedSink: fix a format string bug

Repository: incubator-beam Updated Branches: refs/heads/master 7725a47a7 -> da1b7556b FileBasedSink: fix a format string bug Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3ff02950 Tree:

[2/2] incubator-beam git commit: Closes #306

Closes #306 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/da1b7556 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/da1b7556 Diff:

[GitHub] incubator-beam pull request: FileBasedSink: fix a format string bu...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/306 FileBasedSink: fix a format string bug R: @lukecwik @kennknowles @peihe @tgroh anyone will do You can merge this pull request into a Git repository by running: $ git pull https

[2/2] incubator-beam git commit: pom.xml: upgrade to version 1.22.0 of the Google API client libs

pom.xml: upgrade to version 1.22.0 of the Google API client libs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2c3c464f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2c3c464f Diff:

[1/2] incubator-beam git commit: Closes #303

Repository: incubator-beam Updated Branches: refs/heads/master 03e99540a -> 199ec2e10 Closes #303 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/199ec2e1 Tree:

[GitHub] incubator-beam pull request: pom.xml: upgrade to version 1.22.0 of...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/303 pom.xml: upgrade to version 1.22.0 of the Google API client libs R: @lukecwik You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi

[1/2] incubator-beam git commit: Move copy and remove from FileBasedSink to GcsUtil.

Repository: incubator-beam Updated Branches: refs/heads/master 51e1e59b8 -> dc4f2f706 Move copy and remove from FileBasedSink to GcsUtil. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c88bfff6 Tree:

[2/2] incubator-beam git commit: Closes #295

Closes #295 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dc4f2f70 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dc4f2f70 Diff:

[1/2] incubator-beam git commit: [BEAM-48] Refactor BigQueryServices to support extract and query jobs

Repository: incubator-beam Updated Branches: refs/heads/master 97945648c -> 928640df2 [BEAM-48] Refactor BigQueryServices to support extract and query jobs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

<    5   6   7   8   9   10   11   12   >