From b933da0e74cafe9b94867a33f433573368667888 Mon Sep 17 00:00:00 2001 From: Robert Metzger Date: Wed, 25 Nov 2015 17:48:35 +0100 Subject: [PATCH] [docs][hotfix] Fix wrong window definitions in the docs --- docs/apis/streaming_guide.md | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md index 626df10d13dab1..b1478614394619 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).

{% highlight java %} -triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS))); +triggeredStream.evictor(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS))); {% endhighlight %} @@ -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.

{% highlight java %} -triggeredStream.evict(CountEvictor.of(1000)); +triggeredStream.evictor(CountEvictor.of(1000)); {% endhighlight %} @@ -2543,7 +2543,7 @@ triggeredStream.evict(CountEvictor.of(1000)); DeltaFunction).

{% highlight java %} -triggeredStream.evict(DeltaEvictor.of(5000, new DeltaFunction() { +triggeredStream.evictor(DeltaEvictor.of(5000, new DeltaFunction() { public double (Double oldValue, Double newValue) { return newValue - oldValue; } @@ -2572,7 +2572,7 @@ triggeredStream.evict(DeltaEvictor.of(5000, new DeltaFunction() { until end-value are retained (the resulting window size is 1 second).

{% highlight scala %} -triggeredStream.evict(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS))); +triggeredStream.evictor(TimeEvictor.of(Time.of(1, TimeUnit.SECONDS))); {% endhighlight %} @@ -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.

{% highlight scala %} -triggeredStream.evict(CountEvictor.of(1000)); +triggeredStream.evictor(CountEvictor.of(1000)); {% endhighlight %} @@ -2596,7 +2596,7 @@ triggeredStream.evict(CountEvictor.of(1000)); DeltaFunction).

{% 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 %} @@ -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 %} @@ -2646,8 +2646,8 @@ stream.countWindow(1000, 100) {% highlight java %} stream.window(GlobalWindows.create()) - .trigger(CountTrigger.of(1000) - .evict(CountEvictor.of(100))) + .evictor(CountEvictor.of(1000)) + .trigger(CountTrigger.of(100)) {% endhighlight %}