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 <m...@apache.org> Authored: Fri Apr 29 17:58:11 2016 +0200 Committer: Maximilian Michels <m...@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(-) ----------------------------------------------------------------------