You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2015/11/18 11:49:05 UTC
flink git commit: [hotfix][docs] Replace Count.of() with appropriate
Count(Trigger|Evictor).of()
Repository: flink
Updated Branches:
refs/heads/master a45212d2b -> 99d52cc69
[hotfix][docs] Replace Count.of() with appropriate Count(Trigger|Evictor).of()
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/99d52cc6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/99d52cc6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/99d52cc6
Branch: refs/heads/master
Commit: 99d52cc69d660e559a0e37978edfa33ec3923948
Parents: a45212d
Author: Robert Metzger <rm...@apache.org>
Authored: Wed Nov 18 11:48:13 2015 +0100
Committer: Robert Metzger <rm...@apache.org>
Committed: Wed Nov 18 11:48:13 2015 +0100
----------------------------------------------------------------------
docs/apis/streaming_guide.md | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/99d52cc6/docs/apis/streaming_guide.md
----------------------------------------------------------------------
diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md
index bc13c0e..5f4b1f6 100644
--- a/docs/apis/streaming_guide.md
+++ b/docs/apis/streaming_guide.md
@@ -2123,8 +2123,8 @@ window, and every time execution is triggered, 10 elements are retained in the w
{% highlight java %}
keyedStream
.window(SlidingTimeWindows.of(Time.of(5, TimeUnit.SECONDS), Time.of(1, TimeUnit.SECONDS))
- .trigger(Count.of(100))
- .evictor(Count.of(10));
+ .trigger(CountTrigger.of(100))
+ .evictor(CountEvictor.of(10));
{% endhighlight %}
</div>
@@ -2132,8 +2132,8 @@ keyedStream
{% highlight scala %}
keyedStream
.window(SlidingTimeWindows.of(Time.of(5, TimeUnit.SECONDS), Time.of(1, TimeUnit.SECONDS))
- .trigger(Count.of(100))
- .evictor(Count.of(10))
+ .trigger(CountTrigger.of(100))
+ .evictor(CountEvictor.of(10))
{% endhighlight %}
</div>
</div>
@@ -2715,8 +2715,8 @@ same:
{% highlight java %}
nonKeyedStream
.windowAll(SlidingTimeWindows.of(Time.of(5, TimeUnit.SECONDS), Time.of(1, TimeUnit.SECONDS))
- .trigger(Count.of(100))
- .evictor(Count.of(10));
+ .trigger(CountTrigger.of(100))
+ .evictor(CountEvictor.of(10));
{% endhighlight %}
</div>
@@ -2724,8 +2724,8 @@ nonKeyedStream
{% highlight scala %}
nonKeyedStream
.windowAll(SlidingTimeWindows.of(Time.of(5, TimeUnit.SECONDS), Time.of(1, TimeUnit.SECONDS))
- .trigger(Count.of(100))
- .evictor(Count.of(10))
+ .trigger(CountTrigger.of(100))
+ .evictor(CountEvictor.of(10))
{% endhighlight %}
</div>
</div>