flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [8/8] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs
Date Thu, 26 Nov 2015 00:20:46 GMT
[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 <rmetzger@apache.org>
Authored: Wed Nov 25 17:48:35 2015 +0100
Committer: Fabian Hueske <fhueske@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>


Mime
View raw message