[readme] add hint that streaming support is available
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8434c3c0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8434c3c0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8434c3c0 Branch: refs/heads/master Commit: 8434c3c0d7fcc01a96199bd9323b2e91914e68c1 Parents: edff078 Author: Max <m...@posteo.de> Authored: Wed Jan 20 17:25:13 2016 +0100 Committer: Davor Bonaci <davorbon...@users.noreply.github.com> Committed: Fri Mar 4 10:04:23 2016 -0800 ---------------------------------------------------------------------- runners/flink/README.md | 8 ++++++-- .../wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java | 2 +- 2 files changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8434c3c0/runners/flink/README.md ---------------------------------------------------------------------- diff --git a/runners/flink/README.md b/runners/flink/README.md index 8c06c1d..54d248c 100644 --- a/runners/flink/README.md +++ b/runners/flink/README.md @@ -142,5 +142,9 @@ the [Mailinglists](http://flink.apache.org/community.html#mailing-lists). # Streaming -Streaming support is currently under development. See the `streaming_new` branch for the current -work in progress version. +Streaming support has been added. It is currently in alpha stage. Please give it a try. To use +streaming, just enable streaming mode in the `PipelineOptions`: + + options.setStreaming(true); + +That's all. \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8434c3c0/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java ---------------------------------------------------------------------- diff --git a/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java b/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java index c52fabe..0f0a9d0 100644 --- a/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java +++ b/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java @@ -48,7 +48,7 @@ import java.util.*; /** * This class is the key class implementing all the windowing/triggering logic of Google Dataflow. * To provide full compatibility and support all the windowing/triggering combinations offered by - * Datadlow, we opted for a strategy that uses the SDK's code for doing these operations + * Dataflow, we opted for a strategy that uses the SDK's code for doing these operations * ({@link com.google.cloud.dataflow.sdk.util.StreamingGroupAlsoByWindowsDoFn}. * <p> * In a nutshell, when the execution arrives to this operator, we expect to have a stream <b>already
