Skip to content

Commit

Permalink
address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Reuven Lax committed Feb 14, 2020
1 parent 94644ce commit ac98b62
Showing 1 changed file with 4 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -407,8 +407,8 @@ public interface MultiOutputReceiver {
* choose to defer fetching state until read() is called. Annotating a state argument with this
* parameter provides a hint to the runner that the state is always fetched. This may cause the
* runner to prefetch all the state before calling the processElement or processTimer method,
* improving performance. This is a performance-only hint - it does not change semantics.
* See the following code for an example:
* improving performance. This is a performance-only hint - it does not change semantics. See the
* following code for an example:
*
* <pre><code>{@literal new DoFn<KV<Key, Foo>, Baz>()} {
*
Expand All @@ -426,13 +426,8 @@ public interface MultiOutputReceiver {
* }
* </code></pre>
*
* <p>State is subject to the following validity conditions:
*
* <ul>
* <li>Each state ID must be declared at most once.
* <li>Any state referenced in a parameter must be declared with the same state type.
* <li>State declarations must be final.
* </ul>
* <p>This can only be used on state objects that implement {@link
* org.apache.beam.sdk.state.ReadableState}.
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
Expand Down

0 comments on commit ac98b62

Please sign in to comment.