[hotfix] Minor code cleanups in AbstractStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d93b154d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d93b154d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d93b154d Branch: refs/heads/master Commit: d93b154d41045e89dcc2238885db83fd947cd104 Parents: b6bfcf0 Author: Stephan Ewen <se...@apache.org> Authored: Thu Feb 11 22:13:37 2016 +0100 Committer: Stephan Ewen <se...@apache.org> Committed: Fri Feb 12 18:51:01 2016 +0100 ---------------------------------------------------------------------- .../apache/flink/runtime/state/AbstractStateBackend.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d93b154d/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java index e989af3..d0c4f82 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java @@ -123,7 +123,7 @@ public abstract class AbstractStateBackend implements java.io.Serializable { * @param <N> The type of the namespace. * @param <T> The type of the value that the {@code ValueState} can store. */ - abstract protected <N, T> ValueState<T> createValueState(TypeSerializer<N> namespaceSerializer, ValueStateDescriptor<T> stateDesc) throws Exception; + protected abstract <N, T> ValueState<T> createValueState(TypeSerializer<N> namespaceSerializer, ValueStateDescriptor<T> stateDesc) throws Exception; /** * Creates and returns a new {@link ListState}. @@ -134,7 +134,7 @@ public abstract class AbstractStateBackend implements java.io.Serializable { * @param <N> The type of the namespace. * @param <T> The type of the values that the {@code ListState} can store. */ - abstract protected <N, T> ListState<T> createListState(TypeSerializer<N> namespaceSerializer, ListStateDescriptor<T> stateDesc) throws Exception; + protected abstract <N, T> ListState<T> createListState(TypeSerializer<N> namespaceSerializer, ListStateDescriptor<T> stateDesc) throws Exception; /** * Creates and returns a new {@link ReducingState}. @@ -145,7 +145,7 @@ public abstract class AbstractStateBackend implements java.io.Serializable { * @param <N> The type of the namespace. * @param <T> The type of the values that the {@code ListState} can store. */ - abstract protected <N, T> ReducingState<T> createReducingState(TypeSerializer<N> namespaceSerializer, ReducingStateDescriptor<T> stateDesc) throws Exception; + protected abstract <N, T> ReducingState<T> createReducingState(TypeSerializer<N> namespaceSerializer, ReducingStateDescriptor<T> stateDesc) throws Exception; /** * Sets the current key that is used for partitioned state. @@ -170,7 +170,7 @@ public abstract class AbstractStateBackend implements java.io.Serializable { * * @param stateDescriptor The state identifier for the state. This contains name * and can create a default state value. - * @param <K> The type of the key. + * @param <N> The type of the namespace. * @param <S> The type of the state. * @@ -179,7 +179,7 @@ public abstract class AbstractStateBackend implements java.io.Serializable { * @throws Exception Exceptions may occur during initialization of the state and should be forwarded. */ @SuppressWarnings({"rawtypes", "unchecked"}) - public <K, N, S extends State> S getPartitionedState(final N namespace, final TypeSerializer<N> namespaceSerializer, final StateDescriptor<S, ?> stateDescriptor) throws Exception { + public <N, S extends State> S getPartitionedState(final N namespace, final TypeSerializer<N> namespaceSerializer, final StateDescriptor<S, ?> stateDescriptor) throws Exception { if (keySerializer == null) { throw new Exception("State key serializer has not been configured in the config. " +
