You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2015/11/26 01:20:46 UTC
[8/8] flink git commit: [docs][hotfix] Fix wrong window definitions
in the docs
[docs][hotfix] Fix wrong window definitions in the docs
This closes #1407
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcce6def
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dcce6def
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dcce6def
Branch: refs/heads/master
Commit: dcce6def98bc0a4ac5bdd431342ce4f70d8afd8e
Parents: 804611c
Author: Robert Metzger <rm...@apache.org>
Authored: Wed Nov 25 17:48:35 2015 +0100
Committer: Fabian Hueske <fh...@apache.org>
Committed: Wed Nov 25 23:53:07 2015 +0100
----------------------------------------------------------------------
docs/apis/streaming_guide.md | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/dcce6def/docs/apis/streaming_guide.md
----------------------------------------------------------------------
diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md
index d61363f..7062a16 100644
--- a/docs/apis/streaming_guide.md
+++ b/docs/apis/streaming_guide.md
@@ -2519,7 +2519,7 @@ implementing the `Evictor` interface.
until end-value are retained (the resulting window size is 1 second).
</p>
{% highlight java %}
-triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
+triggeredStream.evictor(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
{% endhighlight %}
</td>
</tr>
@@ -2530,7 +2530,7 @@ triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
Retain 1000 elements from the end of the window backwards, evicting all others.
</p>
{% highlight java %}
-triggeredStream.evict(CountEvictor.of(1000));
+triggeredStream.evictor(CountEvictor.of(1000));
{% endhighlight %}
</td>
</tr>
@@ -2543,7 +2543,7 @@ triggeredStream.evict(CountEvictor.of(1000));
DeltaFunction).
</p>
{% highlight java %}
-triggeredStream.evict(DeltaEvictor.of(5000, new DeltaFunction<Double>() {
+triggeredStream.evictor(DeltaEvictor.of(5000, new DeltaFunction<Double>() {
public double (Double oldValue, Double newValue) {
return newValue - oldValue;
}
@@ -2572,7 +2572,7 @@ triggeredStream.evict(DeltaEvictor.of(5000, new DeltaFunction<Double>() {
until end-value are retained (the resulting window size is 1 second).
</p>
{% highlight scala %}
-triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
+triggeredStream.evictor(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
{% endhighlight %}
</td>
</tr>
@@ -2583,7 +2583,7 @@ triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS)));
Retain 1000 elements from the end of the window backwards, evicting all others.
</p>
{% highlight scala %}
-triggeredStream.evict(CountEvictor.of(1000));
+triggeredStream.evictor(CountEvictor.of(1000));
{% endhighlight %}
</td>
</tr>
@@ -2596,7 +2596,7 @@ triggeredStream.evict(CountEvictor.of(1000));
DeltaFunction).
</p>
{% highlight scala %}
-windowedStream.evict(DeltaEvictor.of(5000.0, { (old,new) => new - old > 0.01 }))
+windowedStream.evictor(DeltaEvictor.of(5000.0, { (old,new) => new - old > 0.01 }))
{% endhighlight %}
</td>
</tr>
@@ -2632,7 +2632,7 @@ stream.countWindow(1000)
{% highlight java %}
stream.window(GlobalWindows.create())
.trigger(CountTrigger.of(1000)
- .evict(CountEvictor.of(1000)))
+ .evictor(CountEvictor.of(1000)))
{% endhighlight %}
</td>
</tr>
@@ -2646,8 +2646,8 @@ stream.countWindow(1000, 100)
<td>
{% highlight java %}
stream.window(GlobalWindows.create())
- .trigger(CountTrigger.of(1000)
- .evict(CountEvictor.of(100)))
+ .evictor(CountEvictor.of(1000))
+ .trigger(CountTrigger.of(100))
{% endhighlight %}
</td>
</tr>