You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/08/11 13:14:20 UTC
[2/4] flink git commit: [FLINK-2502] [storm compatibility] Fix
FiniteStormSpout documenation rendering - added missing empty lines -
additional minor improvements
[FLINK-2502] [storm compatibility] Fix FiniteStormSpout documenation rendering
- added missing empty lines
- additional minor improvements
This closes #1002
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5bb855ba
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5bb855ba
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5bb855ba
Branch: refs/heads/master
Commit: 5bb855bac7441701495ce47db7ba03ab0e0c6963
Parents: d09fc76
Author: mjsax <mj...@informatik.hu-berlin.de>
Authored: Sun Aug 9 14:22:56 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Aug 11 12:06:49 2015 +0200
----------------------------------------------------------------------
docs/apis/storm_compatibility.md | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/5bb855ba/docs/apis/storm_compatibility.md
----------------------------------------------------------------------
diff --git a/docs/apis/storm_compatibility.md b/docs/apis/storm_compatibility.md
index 1390b92..b38667b 100644
--- a/docs/apis/storm_compatibility.md
+++ b/docs/apis/storm_compatibility.md
@@ -171,10 +171,10 @@ See [BoltTokenizerWordCountPojo](https://github.com/apache/flink/tree/master/fli
## Finite Storm Spouts
-In Flink streaming, sources can be finite - i.e. emit a finite number of records and stop after emitting the last record -, however, Storm spouts always emit infinite streams.
+In Flink streaming, sources can be finite – i.e., emit a finite number of records and stop after emitting the last record –, however, Storm spouts always emit infinite streams.
The bridge between the two approach is the `FiniteStormSpout` interface which, in addition to `IRichSpout`, contains a `reachedEnd()` method, where the user can specify a stopping-condition.
The user can create a finite Storm spout by implementing this interface instead of `IRichSpout`, and implementing the `reachedEnd()`method in addition.
-When used as part of a Flink topology, a `FiniteStormSpout` should be wrapped in a `FiniteStormSpoutWrapper` class.
+When used as part of a Flink topology, a `FiniteStormSpout` should be wrapped by `FiniteStormSpoutWrapper`.
Although finite Storm spouts are not necessary to embed Storm spouts into a Flink streaming program or to submit a whole Storm topology to Flink, there are cases where they may come in handy:
@@ -186,6 +186,7 @@ Although finite Storm spouts are not necessary to embed Storm spouts into a Flin
A `FiniteStormSpout` can be still used as a normal, infinite Storm spout by changing its wrapper class to `StormSpoutWraper` in the Flink topology.
An example of a finite Storm spout that emits records for 10 seconds only:
+
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
~~~java
@@ -203,6 +204,7 @@ public class TimedFiniteStormSpout extends AbstractStormSpout implements FiniteS
</div>
Using a `FiniteStormSpout` in a Flink topology:
+
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
~~~java