This closes #2574
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/686b774c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/686b774c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/686b774c Branch: refs/heads/master Commit: 686b774ceda8bee32032cb421651e8350ca5bf3d Parents: fac4f3e d8213fa Author: Ismaël MejÃa <ieme...@apache.org> Authored: Tue Apr 18 17:28:54 2017 +0200 Committer: Ismaël MejÃa <ieme...@apache.org> Committed: Tue Apr 18 17:28:54 2017 +0200 ---------------------------------------------------------------------- .../examples/streaming/KafkaIOExamples.java | 338 ------------------- .../KafkaWindowedWordCountExample.java | 164 --------- .../FlinkStreamingTransformTranslators.java | 87 +---- .../flink/translation/types/FlinkCoder.java | 63 ---- .../streaming/io/UnboundedFlinkSink.java | 200 ----------- .../streaming/io/UnboundedFlinkSource.java | 120 ------- 6 files changed, 12 insertions(+), 960 deletions(-) ----------------------------------------------------------------------