[hotfix] Making arguments in BroadcastProcessFunction final.

mpdn · Apr 23, 2018 · fb25476 · fb25476
1 parent d519eb7
commit fb25476
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...c/main/java/org/apache/flink/streaming/api/functions/co/BaseBroadcastProcessFunction.java b/...c/main/java/org/apache/flink/streaming/api/functions/co/BaseBroadcastProcessFunction.java
@@ -55,7 +55,7 @@ abstract class BaseContext {
 		 * @param outputTag the {@code OutputTag} that identifies the side output to emit to.
 		 * @param value The record to emit.
 		 */
-		public abstract <X> void output(OutputTag<X> outputTag, X value);
+		public abstract <X> void output(final OutputTag<X> outputTag, final X value);
 
 		/** Returns the current processing time. */
 		public abstract long currentProcessingTime();
@@ -81,7 +81,7 @@ public abstract class Context extends BaseContext {
 		 * @param stateDescriptor the {@link MapStateDescriptor} of the state to be fetched.
 		 * @return The required {@link BroadcastState broadcast state}.
 		 */
-		public abstract <K, V> BroadcastState<K, V> getBroadcastState(MapStateDescriptor<K, V> stateDescriptor);
+		public abstract <K, V> BroadcastState<K, V> getBroadcastState(final MapStateDescriptor<K, V> stateDescriptor);
 	}
 
 	/**
@@ -100,6 +100,6 @@ public abstract class ReadOnlyContext extends BaseContext {
 		 * @param stateDescriptor the {@link MapStateDescriptor} of the state to be fetched.
 		 * @return The required read-only view of the broadcast state.
 		 */
-		public abstract <K, V> ReadOnlyBroadcastState<K, V> getBroadcastState(MapStateDescriptor<K, V> stateDescriptor);
+		public abstract <K, V> ReadOnlyBroadcastState<K, V> getBroadcastState(final MapStateDescriptor<K, V> stateDescriptor);
 	}
 }
diff --git a/...a/src/main/java/org/apache/flink/streaming/api/functions/co/BroadcastProcessFunction.java b/...a/src/main/java/org/apache/flink/streaming/api/functions/co/BroadcastProcessFunction.java
@@ -69,7 +69,7 @@ public abstract class BroadcastProcessFunction<IN1, IN2, OUT> extends BaseBroadc
 	 * @throws Exception The function may throw exceptions which cause the streaming program
 	 *                   to fail and go into recovery.
 	 */
-	public abstract void processElement(IN1 value, ReadOnlyContext ctx, Collector<OUT> out) throws Exception;
+	public abstract void processElement(final IN1 value, final ReadOnlyContext ctx, final Collector<OUT> out) throws Exception;
 
 	/**
 	 * This method is called for each element in the
@@ -89,7 +89,7 @@ public abstract class BroadcastProcessFunction<IN1, IN2, OUT> extends BaseBroadc
 	 * @throws Exception The function may throw exceptions which cause the streaming program
 	 *                   to fail and go into recovery.
 	 */
-	public abstract void processBroadcastElement(IN2 value, Context ctx, Collector<OUT> out) throws Exception;
+	public abstract void processBroadcastElement(final IN2 value, final Context ctx, final Collector<OUT> out) throws Exception;
 
 	/**
 	 * A {@link BaseBroadcastProcessFunction.Context context} available to the broadcast side of