flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/4] flink git commit: [hotfix] Minor code cleanups in AbstractStateBackend
Date Fri, 12 Feb 2016 17:51:36 GMT
[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 <sewen@apache.org>
Authored: Thu Feb 11 22:13:37 2016 +0100
Committer: Stephan Ewen <sewen@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. " +


Mime
View raw message