[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/16e5ab09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16e5ab09 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/16e5ab09 Branch: refs/heads/release-0.10 Commit: 16e5ab09f47644d1a2d161e72d5489928f8b899f Parents: efbfc6a Author: Robert Metzger <rmetz...@apache.org> Authored: Wed Nov 25 17:48:35 2015 +0100 Committer: Fabian Hueske <fhue...@apache.org> Committed: Thu Nov 26 01:32:57 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/16e5ab09/docs/apis/streaming_guide.md ---------------------------------------------------------------------- diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md index 3c47427..5d78d23 100644 --- a/docs/apis/streaming_guide.md +++ b/docs/apis/streaming_guide.md @@ -2511,7 +2511,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> @@ -2522,7 +2522,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> @@ -2535,7 +2535,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; } @@ -2564,7 +2564,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> @@ -2575,7 +2575,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> @@ -2588,7 +2588,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> @@ -2624,7 +2624,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> @@ -2638,8 +2638,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>