diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md index d61363fa686a161419342f2faf6328c7b0464884..7062a167b0aa11b9f2cf40f5592fb87a48f6f2b2 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 %}