beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 05/13: Clean no more needed KVHelpers
Date Fri, 05 Jul 2019 13:53:15 GMT
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 df167632b5334d32c32f8bfb74e7c92aaba2da8f
Author: Etienne Chauchot <echauchot@apache.org>
AuthorDate: Thu Jul 4 11:23:26 2019 +0200

    Clean no more needed KVHelpers
---
 .../spark/structuredstreaming/translation/helpers/KVHelpers.java     | 5 -----
 1 file changed, 5 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 a53a93f..0e37551 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
@@ -29,9 +29,4 @@ public final class KVHelpers {
   public static <K, V> MapFunction<WindowedValue<KV<K, V>>, K> extractKey()
{
     return (MapFunction<WindowedValue<KV<K, V>>, K>) wv -> wv.getValue().getKey();
   }
-
-  /** A Spark {@link MapFunction} for making a KV out of a {@link scala.Tuple2}. */
-  public static <K, V> MapFunction<Tuple2<K, V>, KV<K, V>> tuple2ToKV()
{
-    return (MapFunction<Tuple2<K, V>, KV<K, V>>) tuple2 -> KV.of(tuple2._1,
tuple2._2);
-  }
 }


Mime
View raw message