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

Posted to commits@beam.apache.org by pa...@apache.org on 2018/10/16 22:39:29 UTC

[beam] 01/01: Merge pull request #6637 from lyft/micah_impulse_source

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

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

commit 2f07e6b6b10412b69e48e11abf9bd4ebdf1462d4
Merge: 287d48d a1baf7c
Author: Pablo <pa...@users.noreply.github.com>
AuthorDate: Tue Oct 16 15:39:10 2018 -0700

    Merge pull request #6637 from lyft/micah_impulse_source
    
    [BEAM-5707] Add a periodic, streaming impulse source for Flink portable pipelines

 .../FlinkStreamingPortablePipelineTranslator.java  | 43 +++++++++++
 .../streaming/io/StreamingImpulseSource.java       | 73 ++++++++++++++++++
 sdks/python/apache_beam/examples/flink/__init__.py | 18 +++++
 .../examples/flink/flink_streaming_impulse.py      | 86 ++++++++++++++++++++++
 sdks/python/apache_beam/io/flink/__init__.py       | 18 +++++
 .../io/flink/flink_streaming_impulse_source.py     | 77 +++++++++++++++++++
 6 files changed, 315 insertions(+)