This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a3ef9b72db9ba28108f8f1288dc554f8786af50e Author: Jeyhun Karimov <[email protected]> AuthorDate: Wed Jun 5 21:39:04 2024 +0200 [FLINK-34977][API] Move State interfaces to flink-core-api --- .../org/apache/flink/api/common/state/AggregatingState.java | 0 .../java/org/apache/flink/api/common/state/AppendingState.java | 0 .../java/org/apache/flink/api/common/state/BroadcastState.java | 0 .../main/java/org/apache/flink/api/common/state/ListState.java | 0 .../main/java/org/apache/flink/api/common/state/MapState.java | 0 .../java/org/apache/flink/api/common/state/MergingState.java | 0 .../apache/flink/api/common/state/ReadOnlyBroadcastState.java | 0 .../java/org/apache/flink/api/common/state/ReducingState.java | 0 .../src/main/java/org/apache/flink/api/common/state/State.java | 0 .../java/org/apache/flink/api/common/state/ValueState.java | 4 ++-- pom.xml | 10 ++++++++++ 11 files changed, 12 insertions(+), 2 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/AggregatingState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/AggregatingState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/AggregatingState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/AggregatingState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/AppendingState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/AppendingState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/BroadcastState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/BroadcastState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/BroadcastState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/BroadcastState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/ListState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/ListState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/ListState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/ListState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/MapState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/MapState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/MapState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/MapState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/MergingState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/MergingState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/ReadOnlyBroadcastState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/ReadOnlyBroadcastState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/ReadOnlyBroadcastState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/ReadOnlyBroadcastState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/ReducingState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/ReducingState.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/ReducingState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/ReducingState.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/State.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/State.java similarity index 100% rename from flink-core/src/main/java/org/apache/flink/api/common/state/State.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/State.java diff --git a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java b/flink-core-api/src/main/java/org/apache/flink/api/common/state/ValueState.java similarity index 95% rename from flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java rename to flink-core-api/src/main/java/org/apache/flink/api/common/state/ValueState.java index 9cca938587d..9134e84f869 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java +++ b/flink-core-api/src/main/java/org/apache/flink/api/common/state/ValueState.java @@ -45,8 +45,8 @@ public interface ValueState<T> extends State { * the value returned depends on the current operator input, as the operator maintains an * independent state for each partition. * - * <p>If you didn't specify a default value when creating the {@link ValueStateDescriptor} this - * will return {@code null} when no value was previously set using {@link #update(Object)}. + * <p>If you didn't specify a default value when creating the ValueStateDescriptor this will + * return {@code null} when no value was previously set using {@link #update(Object)}. * * @return The state value corresponding to the current input. * @throws IOException Thrown if the system cannot access the state. diff --git a/pom.xml b/pom.xml index 6d4f1151f74..6c866823069 100644 --- a/pom.xml +++ b/pom.xml @@ -2363,6 +2363,16 @@ under the License. <exclude>@org.apache.flink.annotation.PublicEvolving</exclude> <exclude>@org.apache.flink.annotation.Internal</exclude> <!-- MARKER: start exclusions; these will be wiped by tools/releasing/update_japicmp_configuration.sh --> + <exclude>org.apache.flink.api.common.state.AggregatingState</exclude> + <exclude>org.apache.flink.api.common.state.AppendingState</exclude> + <exclude>org.apache.flink.api.common.state.BroadcastState</exclude> + <exclude>org.apache.flink.api.common.state.ListState</exclude> + <exclude>org.apache.flink.api.common.state.MapState</exclude> + <exclude>org.apache.flink.api.common.state.MergingState</exclude> + <exclude>org.apache.flink.api.common.state.ReadOnlyBroadcastState</exclude> + <exclude>org.apache.flink.api.common.state.ReducingState</exclude> + <exclude>org.apache.flink.api.common.state.State</exclude> + <exclude>org.apache.flink.api.common.state.ValueState</exclude> <exclude>org.apache.flink.api.common.functions.AggregateFunction</exclude> <exclude>org.apache.flink.api.common.functions.ReduceFunction</exclude> <exclude>org.apache.flink.api.common.functions.Function</exclude>
