beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [09/50] [abbrv] incubator-beam git commit: [readme] add hint that streaming support is available
Date Fri, 04 Mar 2016 18:11:04 GMT
[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 <max@posteo.de>
Authored: Wed Jan 20 17:25:13 2016 +0100
Committer: Davor Bonaci <davorbonaci@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


Mime
View raw message