You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by tg...@apache.org on 2018/03/06 18:17:03 UTC

[beam] 01/01: Merge pull request #4717: Make Impulse#create() visible

This is an automated email from the ASF dual-hosted git repository.

tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit d51b28838b39b39a6903e708898eb34b0a5ca2e2
Merge: 5b99fe2 adcf951
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Tue Mar 6 10:16:58 2018 -0800

    Merge pull request #4717: Make Impulse#create() visible
    
    [BEAM-2421] Make Impulse#create() visible

 .../core/construction/JavaReadViaImpulse.java      |  95 +++++++++++++++
 .../core/construction/JavaReadViaImpulseTest.java  | 131 +++++++++++++++++++++
 .../runners/direct/ImpulseEvaluatorFactory.java    | 104 ++++++++++++++++
 .../beam/runners/direct/RootProviderRegistry.java  |   2 +
 .../runners/direct/TransformEvaluatorRegistry.java |   2 +
 .../direct/ImpulseEvaluatorFactoryTest.java        | 120 +++++++++++++++++++
 .../beam/runners/dataflow/DataflowRunner.java      | 118 +++++--------------
 .../org/apache/beam/sdk/transforms/Impulse.java    |   3 +-
 8 files changed, 485 insertions(+), 90 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
tgroh@apache.org.