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 <pabl...@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(+)
