[16/50] [abbrv] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/streaming/TestCountingSource.java -- diff --git a/runners/flink/runner/src/test/java/org/apache/beam/runner

[25/50] [abbrv] beam git commit: This closes #2576

This closes #2576 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/83193698 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/83193698 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/83193698 Branch: refs/heads/gearp

[46/50] [abbrv] beam git commit: add temp dataset location for non-query BigQuerySource

add temp dataset location for non-query BigQuerySource Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/83dc58ee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/83dc58ee Diff: http://git-wip-us.apache.org/repos/asf/beam/di

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

[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: http://git-wi

[23/50] [abbrv] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/pom.xml -- diff --git a/runners/flink/runner/pom.xml b/runners/flink/runner/pom.xml deleted file mode 100644 index 18343ef..000 --- a/runners/flink/

[35/50] [abbrv] 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: http://git-wip-us.apache.org/repos/asf/be

[17/50] [abbrv] beam git commit: [BEAM-1994] Remove Flink examples package

http://git-wip-us.apache.org/repos/asf/beam/blob/cdd2544b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/ReadSourceITCase.java -- diff --git a/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/Read

[2/2] beam git commit: This closes #2663: TextIO & AvroIO no longer validate schemas against IOChannelFactory

This closes #2663: TextIO & AvroIO no longer validate schemas against IOChannelFactory Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e5e1b089 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e5e1b089 Diff: http://git-wi

[1/2] beam git commit: TextIO & AvroIO no longer validate schemas against IOChannelFactory

Repository: beam Updated Branches: refs/heads/master 7e6f1b78b -> e5e1b0894 TextIO & AvroIO no longer validate schemas against IOChannelFactory Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cf96ac4e Tree: http://git-wip-us

[03/50] [abbrv] beam git commit: This closes #2512

This closes #2512 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f30d5b9e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f30d5b9e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f30d5b9e Branch: refs/heads/jstor

[19/50] [abbrv] beam git commit: [BEAM-1922] Close datasource in JdbcIO when possible

[BEAM-1922] Close datasource in JdbcIO when possible Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dc846268 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dc846268 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff

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

This closes #2550 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/946778c5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/946778c5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/946778c5 Branch: refs/heads/jstor

[12/50] [abbrv] beam git commit: [BEAM-1915] Removes use of OldDoFn from Apex

[BEAM-1915] Removes use of OldDoFn from Apex This is the last occurrence of OldDoFn in the Beam repository outside of OldDoFn itself. It's also used in the Dataflow worker, but it can be deleted entirely once we (Dataflow team) take care of that. Project: http://git-wip-us.apache.org/repos/asf/

[07/50] [abbrv] beam git commit: [BEAM-1964] Fix lint issues and pylint upgrade

[BEAM-1964] Fix lint issues and pylint upgrade Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e03cc498 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e03cc498 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e03cc

[11/50] [abbrv] beam git commit: Update Signature of PTransformOverrideFactory

Update Signature of PTransformOverrideFactory This enables replacements to be reobtained with the entire transform that is being replaced. This is required when Side Inputs are part of the input of the PTransform Application, as PTransforms are not applied to their side inputs. Project: http://

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

This closes #2500 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f7d727c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f7d727c0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f7d727c0 Branch: refs/heads/jstor

[02/50] [abbrv] beam git commit: This closes #2539

This closes #2539 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/89ff0b14 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/89ff0b14 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/89ff0b14 Branch: refs/heads/jstor

[27/50] [abbrv] beam git commit: This closes #2426

This closes #2426 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/32a576ab Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/32a576ab Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/32a576ab Branch: refs/heads/jstor

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

This closes #2551 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/14e5cd28 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/14e5cd28 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/14e5cd28 Branch: refs/heads/jstor

[10/50] [abbrv] beam git commit: Update Signature of PTransformOverrideFactory

http://git-wip-us.apache.org/repos/asf/beam/blob/f3b49605/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java -- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/a

[28/50] [abbrv] beam git commit: Remove getSideInputWindow

Remove getSideInputWindow Callers should instead get the Default WindowMappingFn if no explicit WindowMappingFn is available. Migrate all existing callers within the SDK and runners. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/co

[38/50] [abbrv] beam git commit: This closes #2560

This closes #2560 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36e43558 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36e43558 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36e43558 Branch: refs/heads/jstor

[04/50] [abbrv] beam git commit: Rename DoFn.Context#sideOutput to output

http://git-wip-us.apache.org/repos/asf/beam/blob/113471d6/sdks/java/core/src/test/java/org/apache/beam/sdk/values/TypedPValueTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/values/TypedPValueTest.java b

[01/50] [abbrv] beam git commit: [BEAM-1964] Fix lint issues for linter upgrade -2

Repository: beam Updated Branches: refs/heads/jstorm-runner f6a89b0fc -> 58d4b97c0 [BEAM-1964] Fix lint issues for linter upgrade -2 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf474a0b Tree: http://git-wip-us.apache.org

[06/50] [abbrv] beam git commit: Rename DoFn.Context#sideOutput to output

Rename DoFn.Context#sideOutput to output Having two methods, both named output, one which takes the "main output type" and one that takes a tag to specify the type more clearly communicates the actual behavior - sideOutput isn't a "special" way to output, it's the same as output(T), just to a spec

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

This closes #2542 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c2b855f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3c2b855f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3c2b855f Branch: refs/heads/jstor

[09/50] [abbrv] beam git commit: This closes #2501

This closes #2501 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdbadfc9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdbadfc9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdbadfc9 Branch: refs/heads/jstor

[05/50] [abbrv] beam git commit: Rename DoFn.Context#sideOutput to output

http://git-wip-us.apache.org/repos/asf/beam/blob/113471d6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java -- diff --git a/runners/flink/runner/src/main/java/org/apa

[17/50] [abbrv] beam git commit: Fix javadoc warnings

Fix javadoc warnings Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7cf06f59 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7cf06f59 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7cf06f59 Branch: refs/heads/js

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

This closes #2406 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b8f2309 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b8f2309 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b8f2309 Branch: refs/heads/jstor

[15/50] [abbrv] beam git commit: Add javadoc to getCheckpointMark in UnboundedSource

Add javadoc to getCheckpointMark in UnboundedSource Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c62d698f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c62d698f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/

[45/50] [abbrv] beam git commit: Enable flink dependency enforcement and make dependencies explicit

Enable flink dependency enforcement and make dependencies explicit Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f654ff47 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f654ff47 Diff: http://git-wip-us.apache.org/repos

[31/50] [abbrv] beam git commit: Update assertions of source_test_utils from camelcase to underscore-separated.

Update assertions of source_test_utils from camelcase to underscore-separated. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1f66fbdc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1f66fbdc Diff: http://git-wip-us.apac

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

This closes #2549 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fac4f3e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fac4f3e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fac4f3e3 Branch: refs/heads/jstor

[26/50] [abbrv] beam git commit: Remove reference to the isStreaming flag

Remove reference to the isStreaming flag Remove references to DataflowPipelineOptions in PipelineOptions javadoc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4ae4e7dc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4

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

This closes #2533 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8302783c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8302783c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8302783c Branch: refs/heads/jstor

[33/50] [abbrv] beam git commit: Only compile HIFIO ITs when compiling with java 8.

Only compile HIFIO ITs when compiling with java 8. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8330e158 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8330e158 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8

[42/50] [abbrv] beam git commit: [BEAM-59] This closes #2569

[BEAM-59] This closes #2569 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e5568589 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e5568589 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e5568589 Branch: refs/h

[13/50] [abbrv] beam git commit: Removes final minor usages of OldDoFn outside OldDoFn itself

Removes final minor usages of OldDoFn outside OldDoFn itself Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a3b5f968 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a3b5f968 Diff: http://git-wip-us.apache.org/repos/asf/b

[23/50] [abbrv] beam git commit: Javadoc fixups after style guide changes

Javadoc fixups after style guide changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f83a7d58 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f83a7d58 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f83a7d58 B

[50/50] [abbrv] beam git commit: This closes #2672: Merge branch 'master' upto commit 686b774 into jstorm-runner

This closes #2672: Merge branch 'master' upto commit 686b774 into jstorm-runner [BEAM-1993] Remove special unbounded Flink source/sink Remove flink-annotations dependency Fix Javadoc warnings on Flink Runner Enable flink dependency enforcement and make dependencies explicit [BEAM-59] Reg

[25/50] [abbrv] beam git commit: This closes #2554

This closes #2554 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/075b621f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/075b621f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/075b621f Branch: refs/heads/jstor

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

This closes #2553 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85cfd0c7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/85cfd0c7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/85cfd0c7 Branch: refs/heads/jstor

[41/50] [abbrv] beam git commit: [BEAM-59] Register standard FileSystems wherever we register IOChannelFactories

[BEAM-59] Register standard FileSystems wherever we register IOChannelFactories Additionally, drop an unnecessary use of `GcsOptions` in `PipelineRunner`. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b43c92f2 Tree: http://gi

[43/50] [abbrv] beam git commit: Fix Javadoc warnings on Flink Runner

Fix Javadoc warnings on Flink Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fce8d2a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fce8d2a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fce8d2a Branc

[39/50] [abbrv] beam git commit: [BEAM-1991] Sum.SumDoubleFn => Sum.ofDoubles

[BEAM-1991] Sum.SumDoubleFn => Sum.ofDoubles This is left over from commit 78a360eac35507d9a558fc6117bb56b67b8a884e - [x] Make sure the PR title is formatted like: `[BEAM-] Description of pull request` - [x] Make sure tests pass via `mvn clean verify`. (Even better, enable Travis-CI o

[29/50] [abbrv] beam git commit: Add no-else return to pylintrc

Add no-else return to pylintrc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/efa82fab Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/efa82fab Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/efa82fab Branch: ref

[37/50] [abbrv] beam git commit: clean up description for sdk_location

clean up description for sdk_location Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bbdbce6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bbdbce6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3bbdbce6 Bran

[48/50] [abbrv] beam git commit: This closes #2574

This closes #2574 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/686b774c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/686b774c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/686b774c Branch: refs/heads/jstor

[20/50] [abbrv] beam git commit: [BEAM-1922] This closes #2482

[BEAM-1922] This closes #2482 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/588a4d00 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/588a4d00 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/588a4d00 Branch: refs

[44/50] [abbrv] beam git commit: Remove flink-annotations dependency

Remove flink-annotations dependency Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/88513db3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/88513db3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/88513db3 Branch

[40/50] [abbrv] beam git commit: This closes #2565

This closes #2565 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c52ce7c4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c52ce7c4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c52ce7c4 Branch: refs/heads/jstor

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

This closes #2557 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b0cc984 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b0cc984 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b0cc984 Branch: refs/heads/jstor

[21/50] [abbrv] beam git commit: Update Dataflow Worker Version

Update Dataflow Worker Version Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/faece41c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/faece41c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/faece41c Branch: ref

[47/50] [abbrv] beam git commit: [BEAM-1993] Remove special unbounded Flink source/sink

[BEAM-1993] Remove special unbounded Flink source/sink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d8213fa6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d8213fa6 Diff: http://git-wip-us.apache.org/repos/asf/beam/di

[35/50] [abbrv] beam git commit: Set the Project of a Table Reference at Runtime

Set the Project of a Table Reference at Runtime Instead of using the project at job submission time, use the project at job execution time. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b9e65779 Tree: http://git-wip-us.apache

[49/50] [abbrv] beam git commit: Merge branch 'master' upto commit 686b774ceda8bee32032cb421651e8350ca5bf3d into jstorm-runner

Merge branch 'master' upto commit 686b774ceda8bee32032cb421651e8350ca5bf3d into jstorm-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f1e170a5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f1e170a5 Diff: http:/

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

This closes #2536 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4ff244d4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4ff244d4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4ff244d4 Branch: refs/heads/jstor

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

This closes #2546 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a25c7d3c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a25c7d3c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a25c7d3c Branch: refs/heads/jstor

[5/5] beam git commit: This closes #3334: [BEAM-2333] Go to proto and back before running a pipeline in Java DirectRunner

This closes #3334: [BEAM-2333] Go to proto and back before running a pipeline in Java DirectRunner Dehydrate then rehydrate Pipeline before DirectRunner.run() Add Pipeline rehydration from proto Fix tests that passed invalid input to DynamicDestinations Add stub DisplayDataTranslation P

[4/5] beam git commit: Dehydrate then rehydrate Pipeline before DirectRunner.run()

Dehydrate then rehydrate Pipeline before DirectRunner.run() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8ca45915 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8ca45915 Diff: http://git-wip-us.apache.org/repos/asf/be

[2/5] beam git commit: Add stub DisplayDataTranslation

Add stub DisplayDataTranslation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/efe2dc17 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/efe2dc17 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/efe2dc17 Branch: re

[1/5] beam git commit: Fix tests that passed invalid input to DynamicDestinations

Repository: beam Updated Branches: refs/heads/master 0064fb37a -> 01408c864 Fix tests that passed invalid input to DynamicDestinations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12c277f3 Tree: http://git-wip-us.apache.o

[3/5] beam git commit: Add Pipeline rehydration from proto

Add Pipeline rehydration from proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43481595 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/43481595 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/43481595 Branch

[1/2] beam git commit: ReduceFnRunner: test when watermark leapfrogs EOW and GC

Repository: beam Updated Branches: refs/heads/master 01408c864 -> 73da9cc40 ReduceFnRunner: test when watermark leapfrogs EOW and GC This is known to fail in older versions; forward porting regression test. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.a

[2/2] beam git commit: This closes #3598: ReduceFnRunner: test when watermark leapfrogs EOW and GC

This closes #3598: ReduceFnRunner: test when watermark leapfrogs EOW and GC Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/73da9cc4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/73da9cc4 Diff: http://git-wip-us.apache.

[1/2] beam git commit: Fix View.asMultimap javadoc.

Repository: beam Updated Branches: refs/heads/master da3b8bfde -> 7ab8954b9 Fix View.asMultimap javadoc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0884be52 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0884be5

[2/2] beam git commit: This closes #3656: Fix View.asMultimap javadoc.

This closes #3656: Fix View.asMultimap javadoc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7ab8954b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7ab8954b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7ab8

[5/8] beam git commit: Require java 8 for precommit tests and add gearpump-runner

Require java 8 for precommit tests and add gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a282165c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a282165c Diff: http://git-wip-us.apache.org/repos/asf/bea

[1/8] beam git commit: Revert accidental changes to sdks/java/pom.xml

Repository: beam Updated Branches: refs/heads/gearpump-runner 1ce60b488 -> c35febf1a Revert accidental changes to sdks/java/pom.xml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e655f53c Tree: http://git-wip-us.apache.org/

[4/8] beam git commit: Deactivate integration-tests for gearpump-runner by default

Deactivate integration-tests for gearpump-runner by default Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d9bb4cb6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d9bb4cb6 Diff: http://git-wip-us.apache.org/repos/asf/be

[8/8] beam git commit: This closes #3637: [BEAM-79] Prepare for merging gearpump-runner

This closes #3637: [BEAM-79] Prepare for merging gearpump-runner Remove gearpump-runner in precommit tests Override maven-enforcer-plugin for precommit tests Require java 8 for precommit tests and add gearpump-runner Deactivate integration-tests for gearpump-runner by default Add beam-ru

[2/8] beam git commit: Upgrade BEAM version to 2.2.0-SNAPSHOT in gearpump-runner

Upgrade BEAM version to 2.2.0-SNAPSHOT in gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/daa75669 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/daa75669 Diff: http://git-wip-us.apache.org/repos/asf/beam

[7/8] beam git commit: Remove gearpump-runner in precommit tests

Remove gearpump-runner in precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf154835 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf154835 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bf154835

[3/8] beam git commit: Add beam-runners-gearpump dependency to javadoc

Add beam-runners-gearpump dependency to javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/49d4ed59 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/49d4ed59 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/49d4

[6/8] beam git commit: Override maven-enforcer-plugin for precommit tests

Override maven-enforcer-plugin for precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/18daed90 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/18daed90 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1

[06/50] [abbrv] beam git commit: This closes #2150: Add SideInput support for GearpumpRunner

This closes #2150: Add SideInput support for GearpumpRunner enable ParDoTest [BEAM-79] Add SideInput support for GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15a8ad62 Tree: http://git-wip-us.apache.org/rep

[45/50] [abbrv] beam git commit: Deactivate integration-tests for gearpump-runner by default

Deactivate integration-tests for gearpump-runner by default Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d9bb4cb6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d9bb4cb6 Diff: http://git-wip-us.apache.org/repos/asf/be

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

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9e6c9061 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9e6c9061 Diff: http://git-wip-us.apache.org

[03/50] [abbrv] beam git commit: [BEAM-79] Add SideInput support for GearpumpRunner

http://git-wip-us.apache.org/repos/asf/beam/blob/4eb50d15/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/utils/TranslatorUtils.java -- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runner

[05/50] [abbrv] beam git commit: enable ParDoTest

enable ParDoTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3dc8fc81 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3dc8fc81 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3dc8fc81 Branch: refs/heads/master

[39/50] [abbrv] beam git commit: Upgrade to gearpump 0.8.4

Upgrade to gearpump 0.8.4 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22068274 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/22068274 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/22068274 Branch: refs/hea

[17/50] [abbrv] beam git commit: This closes #2610: Merge master into gearpump-runner branch

This closes #2610: Merge master into gearpump-runner branch Update gearpump-runner against master changes. add temp dataset location for non-query BigQuerySource added module option, use more common zero test, show module name in log Modify types for input PCollections of Flatten transform

[02/50] [abbrv] beam git commit: This closes #1935: Support merging windows in GearpumpRunner

This closes #1935: Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d0aed92 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d0aed92 Diff: http://git-wip-us.apache.org/repos/asf/b

[31/50] [abbrv] beam git commit: upgrade to gearpump 0.8.4-SNAPSHOT

upgrade to gearpump 0.8.4-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f61822d4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f61822d4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f61822d4 Branch:

[20/50] [abbrv] beam git commit: This closes #2888: Merge master into gearpump-runner branch

This closes #2888: Merge master into gearpump-runner branch Update gearpump-runner against master changes Introduces read/writePubsubMessages Removed coder and formatFn from PubsubIO.Write Removed coder and parseFn from PubsubIO.Read Add Additional CloudObjectTranslators Updating Dataf

[01/50] [abbrv] beam git commit: [BEAM-79] Support merging windows in GearpumpRunner

Repository: beam Updated Branches: refs/heads/master c9abd15e5 -> 89236e3b5 [BEAM-79] Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7af64720 Tree: http://git-wip-us.apache.org/repo

[50/50] [abbrv] beam git commit: This closes #3636: Merge GearpumpRunner to master branch

This closes #3636: Merge GearpumpRunner to master branch Remove gearpump-runner in precommit tests Override maven-enforcer-plugin for precommit tests Require java 8 for precommit tests and add gearpump-runner Deactivate integration-tests for gearpump-runner by default Add beam-runners-ge

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

Update gearpump-runner against master changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12b9719e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/12b9719e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/12b971

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

Merge branch 'master' of https://github.com/apache/beam into sync-master Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fed98c84 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fed98c84 Diff: http://git-wip-us.apache.org

[11/50] [abbrv] beam git commit: [BEAM-972] Add unit tests to Gearpump runner

[BEAM-972] Add unit tests to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb0d333d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eb0d333d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/eb0d333

[48/50] [abbrv] beam git commit: Remove gearpump-runner in precommit tests

Remove gearpump-runner in precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf154835 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf154835 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bf154835

[28/50] [abbrv] beam git commit: Fix side input handling in DoFnFunction

Fix side input handling in DoFnFunction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7653e7ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7653e7ed Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7653e7ed Br

[37/50] [abbrv] beam git commit: This closes #3479: [BEAM-79] Merge master into gearpump-runner branch

This closes #3479: [BEAM-79] Merge master into gearpump-runner branch Don't call .testingPipelineOptions() a second time GCP IO ITs now all use --project option Select SDK distribution based on the selected SDK name [BEAM-2373] Upgrade commons-compress dependency version to 1.14 Define t

[44/50] [abbrv] beam git commit: Add beam-runners-gearpump dependency to javadoc

Add beam-runners-gearpump dependency to javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/49d4ed59 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/49d4ed59 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/49d4

[47/50] [abbrv] beam git commit: Override maven-enforcer-plugin for precommit tests

Override maven-enforcer-plugin for precommit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/18daed90 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/18daed90 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1

[13/50] [abbrv] beam git commit: [BEAM-972] Add more unit test to Gearpump runner

[BEAM-972] Add more unit test to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3138dde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3138dde Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f31

[14/50] [abbrv] beam git commit: This closes #2521: Add more unit test to Gearpump runner

This closes #2521: Add more unit test to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ebbb6139 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ebbb6139 Diff: http://git-wip-us.apache.org/repos/asf/beam/

[34/50] [abbrv] beam git commit: Remove unused codes

Remove unused codes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b21fa04f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b21fa04f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b21fa04f Branch: refs/heads/mas

[07/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f917987 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f917987 Diff: http://git-wi

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