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

Posted to commits@beam.apache.org by mx...@apache.org on 2016/04/29 17:59:00 UTC

[4/4] incubator-beam git commit: This closes #266

This closes #266


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/661a4a89
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/661a4a89
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/661a4a89

Branch: refs/heads/master
Commit: 661a4a893c5afa2f257969bd25d4c01c42693fac
Parents: 4fd9d74 63bce07
Author: Maximilian Michels <mx...@apache.org>
Authored: Fri Apr 29 17:58:11 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Fri Apr 29 17:58:11 2016 +0200

----------------------------------------------------------------------
 .../examples/streaming/KafkaIOExamples.java     | 337 +++++++++++++++++++
 .../FlinkStreamingTransformTranslators.java     |  46 ++-
 .../flink/translation/types/FlinkCoder.java     |  64 ++++
 .../streaming/io/UnboundedFlinkSink.java        | 175 ++++++++++
 .../streaming/io/UnboundedFlinkSource.java      |  12 +-
 5 files changed, 625 insertions(+), 9 deletions(-)
----------------------------------------------------------------------