Skip to content

Commit

Permalink
[hotfix][javadocs] Clarify replacement for deprecated FoldingState
Browse files Browse the repository at this point in the history
This closes apache#5129.
  • Loading branch information
bowenli86 authored and zentol committed Dec 13, 2017
1 parent 402af2a commit 01d0d25
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion docs/dev/stream/state/state.md
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ views for mappings, keys and values can be retrieved using `entries()`, `keys()`
All types of state also have a method `clear()` that clears the state for the currently
active key, i.e. the key of the input element.

<span class="label label-danger">Attention</span> `FoldingState` and `FoldingStateDescriptor` have been deprecated in Flink 1.4 and will be completely removed in the future. A more general alternative will be provided.
<span class="label label-danger">Attention</span> `FoldingState` and `FoldingStateDescriptor` have been deprecated in Flink 1.4 and will be completely removed in the future. Please use `AggregatingState` and `AggregatingStateDescriptor` instead.

It is important to keep in mind that these state objects are only used for interfacing
with state. The state is not necessarily stored inside but might reside on disk or somewhere else.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -441,7 +441,7 @@ public interface RuntimeContext {
* @throws UnsupportedOperationException Thrown, if no partitioned state is available for the
* function (function is not part of a KeyedStream).
*
* @deprecated will be removed in a future version
* @deprecated will be removed in a future version in favor of {@link AggregatingState}
*/
@PublicEvolving
@Deprecated
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
* @param <T> Type of the values folded into the state
* @param <ACC> Type of the value in the state
*
* @deprecated will be removed in a future version
* @deprecated will be removed in a future version in favor of {@link AggregatingState}
*/
@PublicEvolving
@Deprecated
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ public interface KeyedStateStore {
* @throws UnsupportedOperationException Thrown, if no partitioned state is available for the
* function (function is not part of a KeyedStream).
*
* @deprecated will be removed in a future version
* @deprecated will be removed in a future version in favor of {@link AggregatingState}
*/
@PublicEvolving
@Deprecated
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ <IN, ACC, OUT> AggregatingState<IN, OUT> createAggregatingState(
* @param <T> Type of the values folded into the state
* @param <ACC> Type of the value in the state
*
* @deprecated will be removed in a future version
* @deprecated will be removed in a future version in favor of {@link AggregatingState}
*/
@Deprecated
<T, ACC> FoldingState<T, ACC> createFoldingState(FoldingStateDescriptor<T, ACC> stateDesc) throws Exception;
Expand Down

0 comments on commit 01d0d25

Please sign in to comment.