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

Posted to commits@beam.apache.org by ke...@apache.org on 2017/04/25 17:30:43 UTC

[48/50] [abbrv] beam git commit: This closes #2574

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/jstorm-runner
Commit: 686b774ceda8bee32032cb421651e8350ca5bf3d
Parents: fac4f3e d8213fa
Author: Isma�l Mej�a <ie...@apache.org>
Authored: Tue Apr 18 17:28:54 2017 +0200
Committer: Isma�l Mej�a <ie...@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(-)
----------------------------------------------------------------------