Skip to content

Commit

Permalink
[doc] Add ProcessWindowFunction to side output doc
Browse files Browse the repository at this point in the history
  • Loading branch information
bowenli86 authored and aljoscha committed Oct 12, 2017
1 parent 39682c4 commit 4f8d01f
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions docs/dev/stream/side_output.md
Original file line number Diff line number Diff line change
Expand Up @@ -55,9 +55,15 @@ val outputTag = OutputTag[String]("side-output")
Notice how the `OutputTag` is typed according to the type of elements that the side output stream
contains.

Emitting data to a side output is only possible from within a
[ProcessFunction]({{ site.baseurl }}/dev/stream/operators/process_function.html). You can use the `Context` parameter
to emit data to a side output identified by an `OutputTag`:
Emitting data to a side output is possible from the following functions:

- [ProcessFunction]({{ site.baseurl }}/dev/stream/operators/process_function.html)
- [ProcessWindowFunction]({{ site.baseurl }}/dev/windows.html#processwindowfunction)
- ProcessAllWindowFunction

You can use the `Context` parameter, which is exposed to users in the above functions, to emit
data to a side output identified by an `OutputTag`. Here is an example of emitting side output
data from a `ProcessFunction`:

<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
Expand Down

0 comments on commit 4f8d01f

Please sign in to comment.