You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ec...@apache.org on 2019/10/23 12:12:20 UTC
[beam] 03/05: Remove unneeded cast
This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git
commit ebc53fd19d73b8bd31a9d0d507ee3070a27a1e5b
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Wed Oct 23 11:51:49 2019 +0200
Remove unneeded cast
---
.../spark/structuredstreaming/translation/helpers/KVHelpers.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/KVHelpers.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/KVHelpers.java
index 1983eaa..2fa4b1a 100644
--- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/KVHelpers.java
+++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/KVHelpers.java
@@ -25,7 +25,7 @@ import org.apache.spark.api.java.function.MapFunction;
public final class KVHelpers {
/** A Spark {@link MapFunction} for extracting the key out of a {@link KV} for GBK for example. */
- public static <K, V> MapFunction<WindowedValue<KV<K, V>>, K> extractKey() {
- return (MapFunction<WindowedValue<KV<K, V>>, K>) wv -> wv.getValue().getKey();
+ public static <K, V> MapFunction<WindowedValue<KV<K, V>>, K> extractKey() {
+ return wv -> wv.getValue().getKey();
}
}