Commits

Commits on Apr 9, 2017

This closes apache#2420
amitsela
committedApr 9, 2017
[BEAM-1737] Implement a Single-output ParDo as a Multi-output ParDo with a single output.
amitsela
committedApr 9, 2017

Commits on Apr 4, 2017

[BEAM-1875] Remove Spark-runner-custom Hadoop and Avro IOs

amitsela
authored and
iemejia
committedApr 4, 2017

Commits on Mar 29, 2017

This closes apache#2354
amitsela
committedMar 29, 2017
[BEAM-1827] Fix use of deprecated Spark APIs in the runner.
amitsela
committedMar 29, 2017

Commits on Mar 28, 2017

This closes apache#2334
amitsela
committedMar 28, 2017
[BEAM-1815] Force a "default" partitioner based on Spark default parallelism to avoid unnecessary shuffles in
amitsela
committedMar 28, 2017

Commits on Mar 25, 2017

This closes apache#2327
amitsela
committedMar 25, 2017
This closes apache#2314
amitsela
committedMar 25, 2017

Commits on Mar 23, 2017

[BEAM-1717] maven-javadoc-plugin execution id should match the id in apache parent.

amitsela
authored and
davorbonaci
committedMar 23, 2017

Commits on Mar 19, 2017

This closes apache#2272
amitsela
committedMar 19, 2017
[BEAM-1752, BEAM-1582] execute tests that recover from checkpoint in post-commit.
amitsela
committedMar 19, 2017

Commits on Mar 16, 2017

This closes apache#2259
amitsela
committedMar 16, 2017

Commits on Mar 12, 2017

This closes apache#2226
amitsela
committedMar 12, 2017

Commits on Mar 10, 2017

This closes apache#1868
amitsela
committedMar 10, 2017

Commits on Mar 9, 2017

This closes apache#2168
amitsela
committedMar 9, 2017

Commits on Mar 7, 2017

This closes apache#2180
amitsela
committedMar 7, 2017

Commits on Mar 10, 2016

Add spark-streaming support to spark-dataflow

amitsela
authored and
tomwhite
committedMar 10, 2016
Correct input parameter is --inputFile

amitsela
authored and
tomwhite
committedMar 10, 2016