Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2768#discussion_r89129638
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java ---
@@ -37,30 +37,24 @@
* @param <T> Type of the value in the state.
*/
@PublicEvolving
-public interface ValueState<T> extends State {
-
+public interface ValueState<T> extends UpdatableState<T> {
/**
- * Returns the current value for the state. When the state is not
- * partitioned the returned value is the same for all inputs in a given
- * operator instance. If state partitioning is applied, the value
returned
- * depends on the current operator input, as the operator maintains an
- * independent state for each partition.
- *
- * @return The operator state value corresponding to the current input.
- *
+ * Returns the current value for the state. The method performs the same
+ * functionality as {@link State#get()}.
+ *
* @throws IOException Thrown if the system cannot access the state.
*/
+ @Deprecated
--- End diff --
Please also add a `@deprecated` description in the Javadoc, pointing to use
`get()`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
